rkasynq

Documentation

Index

• func GetSpan(ctx context.Context) trace.Span
• func GetTraceId(ctx context.Context) string
• func NewJaegerMid(traceRaw []byte) (asynq.MiddlewareFunc, error)
• type TraceConfig
• type TraceMiddleware
  • func (m *TraceMiddleware) Middleware(h asynq.Handler) asynq.Handler

Functions

func GetSpan

func GetSpan(ctx context.Context) trace.Span

func GetTraceId

func GetTraceId(ctx context.Context) string

func NewJaegerMid

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

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