baggage

type Headers ¶

type Headers map[string]string

Headers is a header map.

type Propagator ¶

type Propagator interface {
	// Extract extracts flow labels from headers
	Extract(headers Headers) flowlabel.FlowLabels

	// Inject emits instructions for envoy how to inject flow labels into
	// headers based on given flow labels and existing headers
	//
	// The returned list is expected to be put in
	// CheckResponse.OkHttpResponse.Headers, so that envoy will take care of
	// injecting appropriate headers.
	Inject(flowLabels flowlabel.FlowLabels, headers Headers) (map[string]string, error)
}

Propagator defines how to extract flow labels (baggage) from and put into headers.

type W3Baggage ¶

type W3Baggage struct{}

W3Baggage handles baggage propagation in a single `baggage` header, as described in https://www.w3.org/TR/baggage/

All baggage items are mapped to flow labels 1:1. This could be tweaked in future: * we can use some prefixing/filtering, * alternatively, we could put _all_ flow labels as a _single_ baggage item (eg. Fn-flow).

func (b W3Baggage) Extract(headers Headers) flowlabel.FlowLabels

func (b W3Baggage) Inject(
	flowLabels flowlabel.FlowLabels,
	headers Headers,
) (map[string]string, error)