Support for Compress option in fb Output forward plugin

apis/fluentbit/v1alpha2/plugins/output/forward_types.go

@@ -30,6 +30,9 @@
 	// Enables at-least-once and receiving server can control rate of traffic.
 	// (Requires Fluentd v0.14.0+ server)
 	RequireAckResponse *bool `json:"requireAckResponse,omitempty"`
+	// Set payload compression mechanism. Option available is 'gzip'
+	// +kubebuilder:validation:Enum=gzip
+	Compress string `json:"compress,omitempty"`
 	// A key string known by the remote Fluentd used for authorization.
 	SharedKey string `json:"sharedKey,omitempty"`
 	// Use this option to connect to Fluentd with a zero-length secret.
@@ -70,6 +73,9 @@
 	if f.RequireAckResponse != nil {
 		kvs.Insert("Require_ack_response", fmt.Sprint(*f.RequireAckResponse))
 	}
+	if f.Compress != nil {
+		kvs.Insert("Compress", fmt.Sprint(*f.Compress))
+	}
 	if f.SharedKey != "" {
 		kvs.Insert("Shared_Key", f.SharedKey)
 	}

charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_clusteroutputs.yaml

@@ -1147,6 +1147,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.

charts/fluent-operator/charts/fluent-bit-crds/crds/fluentbit.fluent.io_outputs.yaml

@@ -1147,6 +1147,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.

config/crd/bases/fluentbit.fluent.io_clusteroutputs.yaml

@@ -1147,6 +1147,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.

config/crd/bases/fluentbit.fluent.io_outputs.yaml

@@ -1147,6 +1147,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.

docs/plugins/fluentbit/output/forward.md

@@ -10,6 +10,7 @@ Forward is the protocol used by Fluentd to route messages between peers. <br />
 | tag | Overwrite the tag as we transmit. This allows the receiving pipeline start fresh, or to attribute source. | string |
 | timeAsInteger | Set timestamps in integer format, it enable compatibility mode for Fluentd v0.12 series. | *bool |
 | sendOptions | Always send options (with \"size\"=count of messages) | *bool |
+| compress | Set payload compression mechanism. Option available is 'gzip' | string |
 | requireAckResponse | Send \"chunk\"-option and wait for \"ack\" response from server. Enables at-least-once and receiving server can control rate of traffic. (Requires Fluentd v0.14.0+ server) | *bool |
 | sharedKey | A key string known by the remote Fluentd used for authorization. | string |
 | emptySharedKey | Use this option to connect to Fluentd with a zero-length secret. | *bool |

manifests/setup/fluent-operator-crd.yaml

@@ -5196,6 +5196,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available 
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.
@@ -34026,6 +34032,11 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.

manifests/setup/setup.yaml

@@ -5196,6 +5196,10 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available 
+                      is 'gzip'
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.
@@ -34026,6 +34030,12 @@ spec:
                     maximum: 65535
                     minimum: 1
                     type: integer
+                  compress:
+                    description: Set payload compression mechanism. Option available
+                      is 'gzip'
+                    enum:
+                    - gzip
+                    type: string
                   requireAckResponse:
                     description: |-
                       Send "chunk"-option and wait for "ack" response from server.