package
3.65.0
Repository: https://github.com/jeffail/benthos.git
Documentation: pkg.go.dev

# Functions

CollapsedCount attempts to extract the actual number of messages that were collapsed into the resulting message part.
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.

# Structs

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.

# Interfaces

WalkableError is an interface implemented by batch errors that allows you to walk the messages of the batch and dig into the individual errors.

# Type aliases

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