feat(opensearch): add option to enable gzip compression

Signed-off-by: Timon Engelke <[email protected]>

Author: timonegk

README.md

@@ -201,6 +201,8 @@ receivers:
         insecureSkipVerify: true|false # optional, if set to true, the tls cert won't be verified
         serverName: # optional, the domain, the certificate was issued for, in case it doesn't match the hostname used for the connection
         caFile: # optional, path to the CA file of the trusted authority the cert was signed with
+      # If set to true, gzip compression is used for requests to OpenSearch. Defaults to false.
+      compressRequestBody: true|false
 ```
 
 ### Slack

pkg/sinks/opensearch.go

@@ -25,12 +25,13 @@ type OpenSearchConfig struct {
 	// Indexing preferences
 	UseEventID bool `yaml:"useEventID"`
 	// DeDot all labels and annotations in the event. For both the event and the involvedObject
-	DeDot       bool                   `yaml:"deDot"`
-	Index       string                 `yaml:"index"`
-	IndexFormat string                 `yaml:"indexFormat"`
-	Type        string                 `yaml:"type"`
-	TLS         TLS                    `yaml:"tls"`
-	Layout      map[string]interface{} `yaml:"layout"`
+	DeDot               bool                   `yaml:"deDot"`
+	Index               string                 `yaml:"index"`
+	IndexFormat         string                 `yaml:"indexFormat"`
+	Type                string                 `yaml:"type"`
+	TLS                 TLS                    `yaml:"tls"`
+	Layout              map[string]interface{} `yaml:"layout"`
+	CompressRequestBody bool                   `yaml:"compressRequestBody"`
 }
 
 func NewOpenSearch(cfg *OpenSearchConfig) (*OpenSearch, error) {
@@ -47,6 +48,7 @@ func NewOpenSearch(cfg *OpenSearchConfig) (*OpenSearch, error) {
 		Transport: &http.Transport{
 			TLSClientConfig: tlsClientConfig,
 		},
+		CompressRequestBody: cfg.CompressRequestBody,
 	})
 	if err != nil {
 		return nil, err