Documentation
¶
Index ¶
- type Middleware
- func (m *Middleware) DispatchMiddleware() natasks.DispatchMiddleware
- func (m *Middleware) Extract(ctx context.Context, carrier natasks.TextMapCarrier) context.Context
- func (m *Middleware) Inject(ctx context.Context, carrier natasks.TextMapCarrier)
- func (m *Middleware) ProcessMiddleware(queue string) natasks.ProcessMiddleware
- type Options
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Middleware ¶
type Middleware struct {
// contains filtered or unexported fields
}
func New ¶
func New(opts Options) *Middleware
func (*Middleware) DispatchMiddleware ¶
func (m *Middleware) DispatchMiddleware() natasks.DispatchMiddleware
func (*Middleware) Extract ¶
func (m *Middleware) Extract(ctx context.Context, carrier natasks.TextMapCarrier) context.Context
func (*Middleware) Inject ¶
func (m *Middleware) Inject(ctx context.Context, carrier natasks.TextMapCarrier)
func (*Middleware) ProcessMiddleware ¶
func (m *Middleware) ProcessMiddleware(queue string) natasks.ProcessMiddleware
type Options ¶
type Options struct {
TracerProvider trace.TracerProvider
Propagator propagation.TextMapPropagator
InstrumentationName string
}
Click to show internal directories.
Click to hide internal directories.