rkasynq

Sep 21, 2022

Changes in this version

+ func NewFileExporter(outputPath string, opts ...stdouttrace.Option) sdktrace.SpanExporter

+ func NewJaegerExporter(opt jaeger.EndpointOption) sdktrace.SpanExporter

+ func NewNoopExporter() sdktrace.SpanExporter

+ type NoopExporter struct

+ func (nsb *NoopExporter) ExportSpans(context.Context, []sdktrace.ReadOnlySpan) error

+ func (nsb *NoopExporter) Shutdown(context.Context) error

+ type Option func(*TraceMiddleware)

+ func ToOptions(config *TraceConfig) []Option

+ func WithExporter(exporter sdktrace.SpanExporter) Option

Sep 19, 2022

Changes in this version

+ func EndSpan(span trace.Span, success bool)

+ func GetPropagator(ctx context.Context) propagation.TextMapPropagator

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

+ func GetTracer(ctx context.Context) trace.Tracer

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

Sep 16, 2022

Changes in this version

+ func GetSpan(ctx context.Context) trace.Span

+ func GetTraceId(ctx context.Context) string

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

+ type TraceConfig struct

+ Asynq struct{ ... }

+ type TraceMiddleware struct

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