Documentation
¶
Overview ¶
Package queue propagates correlation metadata through backend-neutral queue metadata maps. Each Receive call creates a distinct delivery-attempt ID.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidOptions = errors.New("queue correlation: invalid options")
ErrInvalidOptions reports invalid queue propagation configuration.
Functions ¶
This section is empty.
Types ¶
type Adapter ¶
type Adapter struct {
// contains filtered or unexported fields
}
Adapter explicitly sends and receives queue metadata.
func New ¶
func New(factory *correlation.Factory, options Options) (*Adapter, error)
New constructs a queue adapter.
func (*Adapter) Receive ¶
func (adapter *Adapter) Receive(metadata map[string]string, trusted bool) (correlation.Values, error)
Receive creates a fresh delivery-attempt ID. trusted must be explicitly true only after the queue backend's metadata boundary has been authenticated.
func (*Adapter) Send ¶
func (adapter *Adapter) Send(metadata map[string]string, parent correlation.Values) (correlation.Values, error)
Send creates a message hop and injects it into an application-owned map.
type Options ¶
type Options struct {
Codec correlation.CodecOptions
}
Options configure queue metadata validation and field names.
Source Files
Click to show internal directories.
Click to hide internal directories.