tracing

Documentation

Index

• func ExtractEventsSpan(tracer opentracing.Tracer, m *kafka.Message) (opentracing.SpanContext, error)
• func ExtractGrpcSpan(tracer opentracing.Tracer, ctx context.Context) (opentracing.SpanContext, error)
• func ExtractHttpSpan(tracer opentracing.Tracer, r *http.Request) (opentracing.SpanContext, error)
• func InjectEventsSpan(span opentracing.Span, m *kafka.Message) error
• func InjectGrpcSpan(span opentracing.Span, ctx context.Context) (context.Context, error)
• func InjectHttpSpan(span opentracing.Span, request *http.Request) error
• func NewTracer(ctx context.Context, c *config.Config, logger *zap.Logger) (opentracing.Tracer, error)
• func StartSpanFromEventsRequest(tracer opentracing.Tracer, m *kafka.Message) opentracing.Span
• func StartSpanFromGrpcRequest(tracer opentracing.Tracer, ctx context.Context) opentracing.Span
• func StartSpanFromHttpRequest(tracer opentracing.Tracer, r *http.Request) opentracing.Span
• type JaegerLogger
  • func NewJeagerLogger(l *zap.Logger) JaegerLogger

Functions

func ExtractEventsSpan

func ExtractEventsSpan(tracer opentracing.Tracer, m *kafka.Message) (opentracing.SpanContext, error)

func ExtractGrpcSpan

func ExtractGrpcSpan(tracer opentracing.Tracer, ctx context.Context) (opentracing.SpanContext, error)

func ExtractHttpSpan

func ExtractHttpSpan(tracer opentracing.Tracer, r *http.Request) (opentracing.SpanContext, error)

func InjectEventsSpan

func InjectEventsSpan(span opentracing.Span, m *kafka.Message) error

func InjectGrpcSpan

func InjectGrpcSpan(span opentracing.Span, ctx context.Context) (context.Context, error)

func InjectHttpSpan

func InjectHttpSpan(span opentracing.Span, request *http.Request) error

func NewTracer

func NewTracer(ctx context.Context, c *config.Config, logger *zap.Logger) (opentracing.Tracer, error)

func StartSpanFromEventsRequest

func StartSpanFromEventsRequest(tracer opentracing.Tracer, m *kafka.Message) opentracing.Span

func StartSpanFromGrpcRequest

func StartSpanFromGrpcRequest(tracer opentracing.Tracer, ctx context.Context) opentracing.Span

func StartSpanFromHttpRequest

func StartSpanFromHttpRequest(tracer opentracing.Tracer, r *http.Request) opentracing.Span

Types

type JaegerLogger

type JaegerLogger interface {
	Error(msg string)
	Debug(msg string)
	Infof(msg string, args ...interface{})
}

func NewJeagerLogger

func NewJeagerLogger(l *zap.Logger) JaegerLogger