Documentation ¶
Index ¶
- type Instrumenter
- func (o *Instrumenter) OnMessageDeserialized(ctx context.Context, message *hedwig.Message)
- func (o *Instrumenter) OnPublish(ctx context.Context, message *hedwig.Message, attributes map[string]string) (context.Context, map[string]string, func())
- func (o *Instrumenter) OnReceive(ctx context.Context, attributes map[string]string) (context.Context, func())
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Instrumenter ¶ added in v0.8.0
type Instrumenter struct {
// contains filtered or unexported fields
}
func NewInstrumenter ¶
func NewInstrumenter(tracerProvider trace.TracerProvider, propagator propagation.TextMapPropagator) *Instrumenter
func (*Instrumenter) OnMessageDeserialized ¶ added in v0.8.0
func (o *Instrumenter) OnMessageDeserialized(ctx context.Context, message *hedwig.Message)
Click to show internal directories.
Click to hide internal directories.