Function newOtelGRPCExporterWithAuth

integration/util/harness_api_writes.go:135–186

(endpoint, orgID, basicAuthToken string, useTLS bool)

}

func newOtelGRPCExporterWithAuth(endpoint, orgID, basicAuthToken string, useTLS bool) (exporter.Traces, error) {
	factory := otlpexporter.NewFactory()
	exporterCfg := factory.CreateDefaultConfig()
	otlpCfg := exporterCfg.(*otlpexporter.Config)

	// Configure headers for authentication (gRPC metadata format)
	var headers configopaque.MapList
	if orgID != "" {
		headers.Set(xScopeOrgIDHeader, configopaque.String(orgID))
	}
	if basicAuthToken != "" {
		headers.Set(authorizationHeader, configopaque.String("Basic "+basicAuthToken))
	}

	otlpCfg.ClientConfig = configgrpc.ClientConfig{
		Endpoint: endpoint,
		TLS: configtls.ClientConfig{
			Insecure: !useTLS,
		},
		Headers: headers,
	}

	// Disable retries to get immediate error feedback
	otlpCfg.RetryConfig.Enabled = false
	// Disable queueing
	otlpCfg.QueueConfig = configoptional.None[exporterhelper.QueueBatchConfig]()
	// beef up the timeout to 30 seconds to avoid flakes
	otlpCfg.TimeoutConfig.Timeout = 30 * time.Second

	logger, _ := zap.NewDevelopment()
	te, err := factory.CreateTraces(
		context.Background(),
		exporter.Settings{
			ID: component.MustNewID(factory.Type().String()),
			TelemetrySettings: component.TelemetrySettings{
				Logger:         logger,
				TracerProvider: tnoop.NewTracerProvider(),
				MeterProvider:  mnoop.NewMeterProvider(),
			},
			BuildInfo: component.NewDefaultBuildInfo(),
		},
		otlpCfg,
	)
	if err != nil {
		return nil, err
	}
	err = te.Start(context.Background(), componenttest.NewNopHost())
	if err != nil {
		return nil, err
	}
	return te, nil
}

type JaegerToOTLPExporter struct {
	exporter exporter.Traces