tracing

Documentation

Index

• func GetKafkaTracingHeadersFromSpanCtx(spanCtx opentracing.SpanContext) []kafka.Header
• func GetTextMapCarrierFromMetaData(ctx context.Context) opentracing.TextMapCarrier
• func InjectTextMapCarrier(spanCtx opentracing.SpanContext) (opentracing.TextMapCarrier, error)
• func InjectTextMapCarrierToGrpcMetaData(ctx context.Context, spanCtx opentracing.SpanContext) context.Context
• func NewJaegerTracer(jaegerConfig *Config) (opentracing.Tracer, io.Closer, error)
• func StartGrpcServerTracerSpan(ctx context.Context, operationName string) (context.Context, opentracing.Span)
• func StartHttpServerTracerSpan(c echo.Context, operationName string) (context.Context, opentracing.Span)
• func StartKafkaConsumerTracerSpan(ctx context.Context, headers []kafka.Header, operationName string) (context.Context, opentracing.Span)
• func TextMapCarrierFromKafkaMessageHeaders(headers []kafka.Header) opentracing.TextMapCarrier
• func TextMapCarrierToKafkaMessageHeaders(textMap opentracing.TextMapCarrier) []kafka.Header
• type Config

Functions

func GetKafkaTracingHeadersFromSpanCtx

func GetKafkaTracingHeadersFromSpanCtx(spanCtx opentracing.SpanContext) []kafka.Header

GetKafkaTracingHeadersFromSpanCtx ...

func GetTextMapCarrierFromMetaData

func GetTextMapCarrierFromMetaData(ctx context.Context) opentracing.TextMapCarrier

GetTextMapCarrierFromMetaData ...

func InjectTextMapCarrier

func InjectTextMapCarrier(spanCtx opentracing.SpanContext) (opentracing.TextMapCarrier, error)

InjectTextMapCarrier ...

func InjectTextMapCarrierToGrpcMetaData

func InjectTextMapCarrierToGrpcMetaData(ctx context.Context, spanCtx opentracing.SpanContext) context.Context

InjectTextMapCarrierToGrpcMetaData ...

func NewJaegerTracer

func NewJaegerTracer(jaegerConfig *Config) (opentracing.Tracer, io.Closer, error)

NewJaegerTracer constructs a new tracer

func StartGrpcServerTracerSpan

func StartGrpcServerTracerSpan(ctx context.Context, operationName string) (context.Context, opentracing.Span)

StartGrpcServerTracerSpan ...

func StartHttpServerTracerSpan

func StartHttpServerTracerSpan(c echo.Context, operationName string) (context.Context, opentracing.Span)

StartHttpServerTracerSpan ...

func StartKafkaConsumerTracerSpan

func StartKafkaConsumerTracerSpan(ctx context.Context, headers []kafka.Header, operationName string) (context.Context, opentracing.Span)

StartKafkaConsumerTracerSpan ...

func TextMapCarrierFromKafkaMessageHeaders

func TextMapCarrierFromKafkaMessageHeaders(headers []kafka.Header) opentracing.TextMapCarrier

TextMapCarrierFromKafkaMessageHeaders ...

func TextMapCarrierToKafkaMessageHeaders

func TextMapCarrierToKafkaMessageHeaders(textMap opentracing.TextMapCarrier) []kafka.Header

TextMapCarrierToKafkaMessageHeaders ...

Types

type Config

type Config struct {
	ServiceName string `mapstructure:"serviceName"`
	HostPort    string `mapstructure:"hostPort"`
	Enable      bool   `mapstructure:"enable"`
	LogSpans    bool   `mapstructure:"logSpans"`
}

Config structures jaeger settings for service tracing