propagation

package

v1.1.0 Latest Latest Go to latest Published: Aug 28, 2026 License: MIT Imports: 5 Imported by: 0

Details

Package propagation provides bounded W3C propagation with explicit inbound trust decisions.

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	BaggageEnabled     bool
	TrustedBaggageKeys []string
	MaxHeaderBytes     int
	MaxBaggageItems    int
}

Config bounds propagation input and allow-lists baggage keys.

func DefaultConfig() Config

DefaultConfig returns conservative propagation bounds. Baggage is disabled until applications define a trusted key contract.

type Policy struct {
	// contains filtered or unexported fields
}

Policy implements the standard TextMapPropagator interface. Its Extract method treats all inbound carriers as untrusted.

func New(config Config) (*Policy, error)

New validates and constructs a propagation policy.

func (p *Policy) Extract(ctx context.Context, carrier otelpropagation.TextMapCarrier) context.Context

Extract applies the untrusted inbound policy: valid W3C trace context is accepted, while all baggage is removed.

func (p *Policy) ExtractTrusted(ctx context.Context, carrier otelpropagation.TextMapCarrier) context.Context

ExtractTrusted accepts only allow-listed, bounded baggage from a trusted peer while applying the same bounded trace-context parsing.

func (p *Policy) Fields() []string

Fields returns every carrier field this policy may read or write.

func (p *Policy) Inject(ctx context.Context, carrier otelpropagation.TextMapCarrier)

Inject replaces outbound W3C headers and propagates only allow-listed, bounded baggage.