otel

Documentation

Index

• func ExtractAMQPHeaders(ctx context.Context, headers map[string]interface{}) context.Context
• func InjectAMQPHeaders(ctx context.Context) map[string]interface{}
• func TracerProvider(ctx context.Context, cfg *JaegerConfig, log logger.ILogger) (trace.Tracer, error)
• type AmqpHeadersCarrier
  • func (a AmqpHeadersCarrier) Get(key string) string
  • func (a AmqpHeadersCarrier) Keys() []string
  • func (a AmqpHeadersCarrier) Set(key string, value string)
• type JaegerConfig

Functions

func ExtractAMQPHeaders

func ExtractAMQPHeaders(ctx context.Context, headers map[string]interface{}) context.Context

ExtractAMQPHeaders extracts the tracing from the header and puts it into the context

func InjectAMQPHeaders

func InjectAMQPHeaders(ctx context.Context) map[string]interface{}

InjectAMQPHeaders injects the tracing from the context into the header map

func TracerProvider

func TracerProvider(ctx context.Context, cfg *JaegerConfig, log logger.ILogger) (trace.Tracer, error)

Types

type AmqpHeadersCarrier

type AmqpHeadersCarrier map[string]interface{}

func (AmqpHeadersCarrier) Get

func (a AmqpHeadersCarrier) Get(key string) string

func (AmqpHeadersCarrier) Keys

func (a AmqpHeadersCarrier) Keys() []string

func (AmqpHeadersCarrier) Set

func (a AmqpHeadersCarrier) Set(key string, value string)

type JaegerConfig

type JaegerConfig struct {
	Server      string `mapstructure:"server"`
	ServiceName string `mapstructure:"serviceName"`
	TracerName  string `mapstructure:"tracerName"`
}