Package policy provides tooling for creating and executing Bento message batch policies.

CollapsedCount attempts to extract the actual number of messages that were collapsed into the resulting message part.

CtxCollapsedCount attempts to extract the actual number of messages that were collapsed into the resulting message part.

CtxWithCollapsedCount returns a message part with a context indicating that this message is the result of collapsing a number of messages.

MessageCollapsedCount attempts to extract the actual number of messages that were combined into the resulting batched message parts.

NewCombinedAcker creates an aggregated that derives one or more ack funcs that, once all of which have been called, the provided root ack func is called.

NewError creates a new batch-wide error, where it's possible to add granular errors for individual messages of the batch.

WithCollapsedCount returns a message part with a context indicating that this message is the result of collapsing a number of messages.

CombinedAcker creates a single ack func closure that aggregates one or more derived closures such that only once each derived closure is called the singular ack func will trigger.

Error is an error type that also allows storing granular errors for each message of a batch.

AckFunc is a common function signature for acknowledging receipt of messages.