The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.