Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Extract ¶
func Extract(ctx context.Context, headers amqp.Table, opts ...Option) ([]label.KeyValue, trace.SpanContext)
Extract returns the correlation context and span context that another service encoded in the rabbitmq Table object with Inject. This function is meant to be used on incoming requests.
Types ¶
type ChannelOption ¶
type ChannelOption func(*channelOptions)
ChannelOption is channel option
func ChannelComopenentName ¶
func ChannelComopenentName(componentName string) ChannelOption
type ConsumeOption ¶
type ConsumeOption func(*consumeOptions)
ConsumeOption is channel option
func ConsumeComopenentName ¶
func ConsumeComopenentName(componentName string) ConsumeOption
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
Consumer is rabbit consumer for trace
type Option ¶
type Option func(*config)
Option is a function that allows configuration of the amqptrace Extract() and Inject() functions
func WithPropagators ¶
func WithPropagators(props propagation.Propagators) Option
WithPropagators sets the propagators to use for Extraction and Injection
Click to show internal directories.
Click to hide internal directories.