CopyJSON recursively creates a deep copy of a JSON structure extracted from a message part.

DeserializeBytes rebuilds a 2D byte array from a binary serialized blob.

FromBytes deserialises a Message from a byte array.

GetAllBytes returns a 2D byte slice representing the raw byte content of the parts of a message.

GetContext either returns a context attached to the message part, or context.Background() if one hasn't been previously attached.

NewPart initializes a new message part.

NewSortGroup creates a sort group associated with a slice of parts.

NewTransaction creates a new transaction object from a message payload and a response channel.

NewTransactionFunc creates a new transaction object that associates a message batch payload with a func used to acknowledge delivery of the message batch.

QuickBatch initializes a new message batch from a 2D byte slice, the slice can be nil, in which case the batch will start empty.

SerializeBytes returns a 2D byte-slice serialized.

TopLevelSortGroup returns the newest sort group to be associated with the given message part, or nil if there is none.

WithContext returns the same message part wrapped with a context, this context can subsequently be received with GetContext.

Errors returned by the message type.

Errors returned by the message type.

Part represents a single Benthos message.

SortGroup associates a tag of a part with the original group.

Transaction is a component that associates a batch of one or more messages with a mechanism that is able to propagate an acknowledgement of delivery back to the source of the batch.

Batch represents zero or more messages.