feat: add Authorization header to OTEL config (CORE-2291) (#708)

ory · Aug 3, 2023 · 21b1639 · 21b1639
1 parent 19829a9
commit 21b1639
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 3 deletions.
diff --git a/configx/provider.go b/configx/provider.go
@@ -454,6 +454,7 @@ func (p *Provider) TracingConfig(serviceName string) *otelx.Config {
  Sampling: otelx.OTLPSampling{
  SamplingRatio: p.Float64("tracing.providers.otlp.sampling.sampling_ratio"),
  },
+ AuthorizationHeader: p.String("tracing.providers.otlp.authorization_header"),
  },
  },
  }

diff --git a/otelx/config.go b/otelx/config.go
@@ -20,9 +20,10 @@ type ZipkinConfig struct {
 }
 
 type OTLPConfig struct {
- ServerURL string `json:"server_url"`
- Insecure bool `json:"insecure"`
- Sampling OTLPSampling `json:"sampling"`
+ ServerURL string `json:"server_url"`
+ Insecure bool `json:"insecure"`
+ Sampling OTLPSampling `json:"sampling"`
+ AuthorizationHeader string `json:"authorization_header"`
 }
 
 type JaegerSampling struct {

diff --git a/otelx/config.schema.json b/otelx/config.schema.json
@@ -134,6 +134,10 @@
  "examples": [0.4]
  }
  }
+ },
+ "authorization_header": {
+ "type": "string",
+ "examples": ["Bearer 2389s8fs9d8fus9f"]
  }
  }
  }

diff --git a/otelx/otlp.go b/otelx/otlp.go
@@ -29,6 +29,12 @@ func SetupOTLP(t *Tracer, tracerName string, c *Config) (trace.Tracer, error) {
  clientOpts = append(clientOpts, otlptracehttp.WithInsecure())
  }
 
+ if c.Providers.OTLP.AuthorizationHeader != "" {
+ clientOpts = append(clientOpts,
+ otlptracehttp.WithHeaders(map[string]string{"Authorization": c.Providers.OTLP.AuthorizationHeader}),
+ )
+ }
+
  exp, err := otlptrace.New(
  ctx, otlptracehttp.NewClient(clientOpts...),
  )