Versions in this module Expand all Collapse all v1 v1.0.0 Aug 25, 2026 Changes in this version + var ErrInvalidOptions = errors.New("queue correlation: invalid options") + type Adapter struct + func New(factory *correlation.Factory, options Options) (*Adapter, error) + func (adapter *Adapter) Receive(metadata map[string]string, trusted bool) (correlation.Values, error) + func (adapter *Adapter) Send(metadata map[string]string, parent correlation.Values) (correlation.Values, error) + type Options struct + Codec correlation.CodecOptions
Go to main page