opentracing

Documentation

Index

• 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 Middleware

type Middleware struct {
	Tracer opentracing.Tracer
}

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