opentelemetry

Documentation

Index

• type MetadataCarrier
  • func (m MetadataCarrier) Get(key string) string
  • func (m MetadataCarrier) Keys() []string
  • func (m MetadataCarrier) Set(key, value string)
• type Middleware
  • func (o Middleware) PublisherMsgInterceptor(serviceName string, next pubsub.PublishHandler) pubsub.PublishHandler
  • func (o Middleware) SubscribeInterceptor(opts pubsub.HandlerOptions, next pubsub.MsgHandler) pubsub.MsgHandler

Types

type MetadataCarrier

type MetadataCarrier map[string]string

func (MetadataCarrier) Get

func (m MetadataCarrier) Get(key string) string

func (MetadataCarrier) Keys

func (m MetadataCarrier) Keys() []string

func (MetadataCarrier) Set

func (m MetadataCarrier) Set(key, value string)

type Middleware

type Middleware struct {
}

Middleware provides opentracing for pubsub to persist traces

func (Middleware) PublisherMsgInterceptor

func (o Middleware) PublisherMsgInterceptor(serviceName string, next pubsub.PublishHandler) pubsub.PublishHandler

PublisherMsgInterceptor inserts opentracing headers into an outgoing msg

func (Middleware) SubscribeInterceptor

func (o Middleware) SubscribeInterceptor(opts pubsub.HandlerOptions, next pubsub.MsgHandler) pubsub.MsgHandler

SubscribeInterceptor returns a subscriber middleware with opentracing