opentracing

Dec 24, 2021

Changes in this version

+ type KafkaHeadersCarrier []kafka.Header

+ func (c *KafkaHeadersCarrier) Set(key, val string)

+ func (c KafkaHeadersCarrier) ForeachKey(handler func(key string, val string) error) error

May 10, 2021

Changes in this version

+ func TraceProducer(tracer opentracing.Tracer, operationName string, ...) endpoint.Middleware

Apr 28, 2021

Changes in this version

+ func ContextToKafka(tracer opentracing.Tracer, logger log.Logger) transport.RequestFunc

+ func KafkaToContext(tracer opentracing.Tracer, operationName string, logger log.Logger) transport.RequestFunc

+ func TraceConsumer(tracer opentracing.Tracer, operationName string, opts ...EndpointOption) endpoint.Middleware

+ func TraceEndpoint(tracer opentracing.Tracer, operationName string, opts ...EndpointOption) endpoint.Middleware

+ type EndpointOption func(*EndpointOptions)

+ func WithIgnoreBusinessError(ignoreBusinessError bool) EndpointOption

+ func WithOperationNameFunc(getOperationName func(ctx context.Context, name string) string) EndpointOption

+ func WithOptions(options EndpointOptions) EndpointOption

+ func WithTags(tags opentracing.Tags) EndpointOption

+ func WithTagsFunc(getTags func(ctx context.Context) opentracing.Tags) EndpointOption

+ type EndpointOptions struct

+ GetOperationName func(ctx context.Context, name string) string

+ GetTags func(ctx context.Context) opentracing.Tags

+ IgnoreBusinessError bool

+ Tags opentracing.Tags

+ type HeadersTextMapCarrier struct

+ func (c *HeadersTextMapCarrier) Set(key, val string)

+ func (c HeadersTextMapCarrier) ForeachKey(handler func(key string, val string) error) error