natsprop

Documentation

Index

• Constants
• func Extract(ctx context.Context, msg *nats.Msg, opts ...Option) ([]attribute.KeyValue, baggage.Baggage, trace.SpanContext)
• func Inject(ctx context.Context, msg *nats.Msg, opts ...Option)
• func NewAttributesFromNATSRequest(msg *nats.Msg) []attribute.KeyValue
• type Option
  • func WithPropagators(props propagation.TextMapPropagator) Option

Constants

const (
	SubjectKey      = attribute.Key("nats.subject")
	SubjectReplySub = attribute.Key("nats.request.subject")
)

Functions

func Extract

func Extract(ctx context.Context, msg *nats.Msg, opts ...Option) ([]attribute.KeyValue, baggage.Baggage, trace.SpanContext)

Extract returns the Attributes, Context Entries, and SpanContext that were encoded by Inject.

func Inject

func Inject(ctx context.Context, msg *nats.Msg, opts ...Option)

func NewAttributesFromNATSRequest

func NewAttributesFromNATSRequest(msg *nats.Msg) []attribute.KeyValue

Types

type Option

type Option interface {
	// contains filtered or unexported methods
}

Option allows configuration of the httptrace Extract() and Inject() functions.

func WithPropagators

func WithPropagators(props propagation.TextMapPropagator) Option

WithPropagators sets the propagators to use for Extraction and Injection