Add zstd compression to SAPM receiver and exporter

- Updated github.com/signalfx/sapm-proto to v0.13.0.
- Added "compression" config setting to sapm exporter.
- Added tests to verify various compression settings for sapm receiver and exporter.

Author: tigrannajaryan

.chloggen/sapm-exporter-zstd.yaml

@@ -0,0 +1,20 @@
+# Use this changelog template to create an entry for release notes.
+# If your change doesn't affect end users, such as a test fix or a tooling change,
+# you should instead start your pull request title with [chore] or use the "Skip Changelog" label.
+
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. filelogreceiver)
+component: sapmexporter
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: sapm exporter now supports `compression` config option to specify either gzip or zstd compression to use.
+
+# Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
+issues: [23257]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext:

.chloggen/sapm-receiver-zstd.yaml

@@ -0,0 +1,20 @@
+# Use this changelog template to create an entry for release notes.
+# If your change doesn't affect end users, such as a test fix or a tooling change,
+# you should instead start your pull request title with [chore] or use the "Skip Changelog" label.
+
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. filelogreceiver)
+component: sapmreceiver
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: sapm receiver now accepts requests in compressed with zstd.
+
+# Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
+issues: [23257]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext:

cmd/configschema/go.mod

@@ -555,7 +555,7 @@ require (
 	github.com/signalfx/com_signalfx_metrics_protobuf v0.0.3 // indirect
 	github.com/signalfx/gohistogram v0.0.0-20160107210732-1ccfd2ff5083 // indirect
 	github.com/signalfx/golib/v3 v3.3.47 // indirect
-	github.com/signalfx/sapm-proto v0.12.0 // indirect
+	github.com/signalfx/sapm-proto v0.13.0 // indirect
 	github.com/sijms/go-ora/v2 v2.7.6 // indirect
 	github.com/sirupsen/logrus v1.9.0 // indirect
 	github.com/snowflakedb/gosnowflake v1.6.18 // indirect

cmd/configschema/go.sum

@@ -572,7 +572,7 @@ require (
 	github.com/signalfx/com_signalfx_metrics_protobuf v0.0.3 // indirect
 	github.com/signalfx/gohistogram v0.0.0-20160107210732-1ccfd2ff5083 // indirect
 	github.com/signalfx/golib/v3 v3.3.47 // indirect
-	github.com/signalfx/sapm-proto v0.12.0 // indirect
+	github.com/signalfx/sapm-proto v0.13.0 // indirect
 	github.com/signalfx/signalfx-agent/pkg/apm v0.0.0-20230214151822-6a6813cf5bf1 // indirect
 	github.com/sijms/go-ora/v2 v2.7.6 // indirect
 	github.com/sirupsen/logrus v1.9.0 // indirect

cmd/otelcontribcol/go.mod

@@ -200,7 +200,7 @@ require (
 	github.com/signalfx/com_signalfx_metrics_protobuf v0.0.3 // indirect
 	github.com/signalfx/gohistogram v0.0.0-20160107210732-1ccfd2ff5083 // indirect
 	github.com/signalfx/golib/v3 v3.3.47 // indirect
-	github.com/signalfx/sapm-proto v0.12.0 // indirect
+	github.com/signalfx/sapm-proto v0.13.0 // indirect
 	github.com/signalfx/signalfx-agent/pkg/apm v0.0.0-20230214151822-6a6813cf5bf1 // indirect
 	github.com/soheilhy/cmux v0.1.5 // indirect
 	github.com/spf13/cobra v1.7.0 // indirect

cmd/otelcontribcol/go.sum

@@ -48,6 +48,11 @@ during final translation.  Intended to be used in tandem with identical configur
 - `timeout` (default = 5s): Is the timeout for every attempt to send data to the backend.
 - `log_detailed_response` (default = `false`): Option to log detailed response from Splunk APM.
 In addition to setting this option to `true`, debug logging at the Collector level needs to be enabled.
+- `compression`: Compression method to use for outgoing SAPM requests. Can be one of
+  "gzip", "zstd" or be unspecified. If unspecified then "gzip" compression is used unless
+  `disable_compression` option is set to true.
+- `disable_compression` (default = `false`): If set to true the outgoing requests are not
+  compressed and `compression` option is ignored.
 
 In addition, this exporter offers queued retry which is enabled by default.
 Information about queued retry configuration parameters can be found

cmd/oteltestbedcol/go.mod

@@ -5,6 +5,7 @@ package sapmexporter // import "github.com/open-telemetry/opentelemetry-collecto
 
 import (
 	"errors"
+	"fmt"
 	"net/url"
 
 	sapmclient "github.com/signalfx/sapm-proto/client"
@@ -35,9 +36,13 @@ type Config struct {
 	// MaxConnections is used to set a limit to the maximum idle HTTP connection the exporter can keep open.
 	MaxConnections uint `mapstructure:"max_connections"`
 
-	// Disable GZip compression.
+	// Disable compression. If set to true then Compression field is ignored.
 	DisableCompression bool `mapstructure:"disable_compression"`
 
+	// Compression method to use (gzip or zstd). Ignored if DisableCompression=true.
+	// If unspecified defaults to gzip.
+	Compression string `mapstructure:"compression"`
+
 	// Log detailed response from trace ingest.
 	LogDetailedResponse bool `mapstructure:"log_detailed_response"`
 
@@ -56,6 +61,17 @@ func (c *Config) Validate() error {
 	if err != nil {
 		return err
 	}
+
+	switch c.Compression {
+	// Valid compression methods.
+	case "", // no compression
+		string(sapmclient.CompressionMethodGzip),
+		string(sapmclient.CompressionMethodZstd):
+
+	default:
+		return fmt.Errorf("invalid compression %q", c.Compression)
+	}
+
 	return nil
 }
 
@@ -85,5 +101,9 @@ func (c *Config) clientOptions() []sapmclient.Option {
 		opts = append(opts, sapmclient.WithDisabledCompression())
 	}
 
+	if c.Compression != "" {
+		opts = append(opts, sapmclient.WithCompressionMethod(sapmclient.CompressionMethod(c.Compression)))
+	}
+
 	return opts
 }