chore: add time_as_integer support to Forward output

Signed-off-by: Davide Rossi <[email protected]>

Author: davide-rossi-ce

charts/logging-operator/crds/logging.banzaicloud.io_clusteroutputs.yaml

@@ -2206,6 +2206,8 @@ spec:
                     type: array
                   slow_flush_log_threshold:
                     type: string
+                  time_as_integer:
+                    type: boolean
                   tls_allow_self_signed_cert:
                     type: boolean
                   tls_cert_logical_store_name:
@@ -9405,6 +9407,8 @@ spec:
                     type: array
                   slow_flush_log_threshold:
                     type: string
+                  time_as_integer:
+                    type: boolean
                   tls_allow_self_signed_cert:
                     type: boolean
                   tls_cert_logical_store_name:

charts/logging-operator/crds/logging.banzaicloud.io_outputs.yaml

@@ -2202,6 +2202,8 @@ spec:
                     type: array
                   slow_flush_log_threshold:
                     type: string
+                  time_as_integer:
+                    type: boolean
                   tls_allow_self_signed_cert:
                     type: boolean
                   tls_cert_logical_store_name:
@@ -8693,6 +8695,8 @@ spec:
                     type: array
                   slow_flush_log_threshold:
                     type: string
+                  time_as_integer:
+                    type: boolean
                   tls_allow_self_signed_cert:
                     type: boolean
                   tls_cert_logical_store_name:

config/crd/bases/logging.banzaicloud.io_clusteroutputs.yaml

@@ -2206,6 +2206,8 @@ spec:
                     type: array
                   slow_flush_log_threshold:
                     type: string
+                  time_as_integer:
+                    type: boolean
                   tls_allow_self_signed_cert:
                     type: boolean
                   tls_cert_logical_store_name:
@@ -9405,6 +9407,8 @@ spec:
                     type: array
                   slow_flush_log_threshold:
                     type: string
+                  time_as_integer:
+                    type: boolean
                   tls_allow_self_signed_cert:
                     type: boolean
                   tls_cert_logical_store_name:

config/crd/bases/logging.banzaicloud.io_outputs.yaml

@@ -2202,6 +2202,8 @@ spec:
                     type: array
                   slow_flush_log_threshold:
                     type: string
+                  time_as_integer:
+                    type: boolean
                   tls_allow_self_signed_cert:
                     type: boolean
                   tls_cert_logical_store_name:
@@ -8693,6 +8695,8 @@ spec:
                     type: array
                   slow_flush_log_threshold:
                     type: string
+                  time_as_integer:
+                    type: boolean
                   tls_allow_self_signed_cert:
                     type: boolean
                   tls_cert_logical_store_name:

docs/configuration/plugins/outputs/forward.md

@@ -111,6 +111,11 @@ Default: 60
 The threshold for chunk flush performance check. Parameter type is float, not time, default: 20.0 (seconds) If chunk flush takes longer time than this threshold, fluentd logs warning message and increases metric fluentd_output_status_slow_flush_count. 
 
 
+### time_as_integer (bool, optional) {#forwardoutput-time_as_integer}
+
+Format forwarded events time as an epoch Integer with second resolution. Useful when forwarding to old ( <= 0.12 ) Fluentd servers. 
+
+
 ### tls_allow_self_signed_cert (bool, optional) {#forwardoutput-tls_allow_self_signed_cert}
 
 Allow self signed certificates or not.

pkg/sdk/logging/model/output/forward.go

@@ -104,6 +104,8 @@ type ForwardOutput struct {
 	// Parameter type is float, not time, default: 20.0 (seconds)
 	// If chunk flush takes longer time than this threshold, fluentd logs warning message and increases metric fluentd_output_status_slow_flush_count.
 	SlowFlushLogThreshold string `json:"slow_flush_log_threshold,omitempty"`
+	// Format forwarded events time as an epoch Integer with second resolution. Useful when forwarding to old ( <= 0.12 ) Fluentd servers.
+	TimeAsInteger bool `json:"time_as_integer,omitempty"`
 }
 
 func (f *ForwardOutput) ToDirective(secretLoader secret.SecretLoader, id string) (types.Directive, error) {