feat: removes trace_format configuration option

Signed-off-by: Dominik Rosiek <[email protected]>

exporter/sumologicexporter/README.md

@@ -101,7 +101,7 @@ exporters:
  decompose_otlp_histograms: {true, false}
 
  # timeout is the timeout for every attempt to send data to the backend,
- # maximum connection timeout is 55s, default = 5s
+ # maximum connection timeout is 55s, default = 30s
  timeout: <timeout>
 
  # defines if sticky session support is enable.

exporter/sumologicexporter/config.go

@@ -51,10 +51,6 @@ type Config struct {
  // Decompose OTLP Histograms into individual metrics, similar to how they're represented in Prometheus format
  DecomposeOtlpHistograms bool `mapstructure:"decompose_otlp_histograms"`
 
- // Traces related configuration
- // The format of traces you will be sending, currently only otlp format is supported
- TraceFormat TraceFormatType `mapstructure:"trace_format"`
-
  // Sumo specific options
  // Name of the client
  Client string `mapstructure:"client"`
@@ -119,12 +115,6 @@ func (cfg *Config) Validate() error {
  return fmt.Errorf("unexpected metric format: %s", cfg.MetricFormat)
  }
 
- switch cfg.TraceFormat {
- case OTLPTraceFormat:
- default:
- return fmt.Errorf("unexpected trace format: %s", cfg.TraceFormat)
- }
-
  if len(cfg.ClientConfig.Endpoint) == 0 && cfg.ClientConfig.Auth == nil {
  return errors.New("no endpoint and no auth extension specified")
  }

exporter/sumologicexporter/config_test.go

@@ -24,7 +24,6 @@ func TestInitExporterInvalidConfiguration(t *testing.T) {
  cfg: &Config{
  LogFormat: "test_format",
  MetricFormat: "otlp",
- TraceFormat: "otlp",
  ClientConfig: confighttp.ClientConfig{
  Timeout: defaultTimeout,
  Endpoint: "test_endpoint",
@@ -70,33 +69,6 @@ func TestInitExporterInvalidConfiguration(t *testing.T) {
  },
  },
  },
- {
- name: "unexpected trace format",
- expectedError: errors.New("unexpected trace format: text"),
- cfg: &Config{
- LogFormat: "json",
- MetricFormat: "otlp",
- TraceFormat: "text",
- ClientConfig: confighttp.ClientConfig{
- Timeout: defaultTimeout,
- Endpoint: "test_endpoint",
- Compression: "gzip",
- },
- },
- },
- {
- name: "no endpoint and no auth extension specified",
- expectedError: errors.New("no endpoint and no auth extension specified"),
- cfg: &Config{
- LogFormat: "json",
- MetricFormat: "otlp",
- TraceFormat: "otlp",
- ClientConfig: confighttp.ClientConfig{
- Timeout: defaultTimeout,
- Compression: "gzip",
- },
- },
- },
  }
 
  for _, tc := range testcases {

exporter/sumologicexporter/exporter_test.go

@@ -50,7 +50,6 @@ func createTestConfig() *Config {
  config.LogFormat = TextFormat
  config.MaxRequestBodySize = 20_971_520
  config.MetricFormat = OTLPMetricFormat
- config.TraceFormat = OTLPTraceFormat
  return config
 }
 

exporter/sumologicexporter/factory.go

@@ -37,7 +37,6 @@ func createDefaultConfig() component.Config {
  LogFormat: DefaultLogFormat,
  MetricFormat: DefaultMetricFormat,
  Client: DefaultClient,
- TraceFormat: OTLPTraceFormat,
 
  ClientConfig: createDefaultClientConfig(),
  BackOffConfig: configretry.NewDefaultBackOffConfig(),

exporter/sumologicexporter/factory_test.go

@@ -34,7 +34,6 @@ func TestCreateDefaultConfig(t *testing.T) {
  LogFormat: "otlp",
  MetricFormat: "otlp",
  Client: "otelcol",
- TraceFormat: "otlp",
 
  ClientConfig: confighttp.ClientConfig{
  Timeout: 30 * time.Second,

exporter/sumologicexporter/sender.go

@@ -599,10 +599,7 @@ func (s *sender) appendAndMaybeSend(
 
 // sendTraces sends traces in right format basing on the s.config.TraceFormat
 func (s *sender) sendTraces(ctx context.Context, td ptrace.Traces) error {
- if s.config.TraceFormat == OTLPTraceFormat {
- return s.sendOTLPTraces(ctx, td)
- }
- return nil
+ return s.sendOTLPTraces(ctx, td)
 }
 
 // sendOTLPTraces sends trace records in OTLP format
@@ -679,14 +676,8 @@ func addMetricsHeaders(req *http.Request, mf MetricFormatType) error {
  return nil
 }
 
-func addTracesHeaders(req *http.Request, tf TraceFormatType) error {
- switch tf {
- case OTLPTraceFormat:
- req.Header.Add(headerContentType, contentTypeOTLP)
- default:
- return fmt.Errorf("unsupported traces format: %s", tf)
- }
- return nil
+func addTracesHeaders(req *http.Request) {
+ req.Header.Add(headerContentType, contentTypeOTLP)
 }
 
 func (s *sender) addRequestHeaders(req *http.Request, pipeline PipelineType, flds fields) error {
@@ -701,9 +692,7 @@ func (s *sender) addRequestHeaders(req *http.Request, pipeline PipelineType, fld
  return err
  }
  case TracesPipeline:
- if err := addTracesHeaders(req, s.config.TraceFormat); err != nil {
- return err
- }
+ addTracesHeaders(req)
  default:
  return fmt.Errorf("unexpected pipeline: %v", pipeline)
  }