rkasynq

Documentation

Index

• func EndSpan(span trace.Span, success bool)
• func GetPropagator(ctx context.Context) propagation.TextMapPropagator
• func GetProvider(ctx context.Context) *sdktrace.TracerProvider
• func GetSpan(ctx context.Context) trace.Span
• func GetTraceId(ctx context.Context) string
• func GetTracer(ctx context.Context) trace.Tracer
• func NewJaegerMid(traceRaw []byte) (asynq.MiddlewareFunc, error)
• func NewSpan(ctx context.Context, name string) (context.Context, trace.Span)
• type TraceConfig
• type TraceMiddleware
  • func (m *TraceMiddleware) Middleware(h asynq.Handler) asynq.Handler

Functions

func EndSpan

func EndSpan(span trace.Span, success bool)

func GetPropagator

func GetPropagator(ctx context.Context) propagation.TextMapPropagator

func GetProvider

func GetProvider(ctx context.Context) *sdktrace.TracerProvider

func GetSpan

func GetSpan(ctx context.Context) trace.Span

func GetTraceId

func GetTraceId(ctx context.Context) string

func GetTracer

func GetTracer(ctx context.Context) trace.Tracer

func NewJaegerMid

func NewJaegerMid(traceRaw []byte) (asynq.MiddlewareFunc, error)

func NewSpan

func NewSpan(ctx context.Context, name string) (context.Context, trace.Span)

Types

type TraceConfig

type TraceConfig struct {
	Asynq struct {
		Trace rkmidtrace.BootConfig `yaml:"trace"`
	} `yaml:"asynq"`
}

type TraceMiddleware

type TraceMiddleware struct {
	// contains filtered or unexported fields
}

func (*TraceMiddleware) Middleware

func (m *TraceMiddleware) Middleware(h asynq.Handler) asynq.Handler