opentracing

Documentation

Index

• 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 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
• type HeadersTextMapCarrier
  • func (c HeadersTextMapCarrier) ForeachKey(handler func(key string, val string) error) error
  • func (c *HeadersTextMapCarrier) Set(key, val string)

Functions

func ContextToKafka

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

func KafkaToContext

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

func TraceConsumer

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

func TraceEndpoint

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

Types

type EndpointOption

type EndpointOption func(*EndpointOptions)

func WithIgnoreBusinessError

func WithIgnoreBusinessError(ignoreBusinessError bool) EndpointOption

func WithOperationNameFunc

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

func WithOptions

func WithOptions(options EndpointOptions) EndpointOption

func WithTags

func WithTags(tags opentracing.Tags) EndpointOption

func WithTagsFunc

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

type EndpointOptions

type EndpointOptions struct {
	IgnoreBusinessError bool

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

	Tags opentracing.Tags

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

type HeadersTextMapCarrier

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

func (HeadersTextMapCarrier) ForeachKey

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

func (*HeadersTextMapCarrier) Set

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