Package batch provides tooling for creating and executing Benthos message batch policies.

Package io provides tooling for serialising and deserialising messages.

Package mapper implements ways of splicing and mapping batches of messages so that their derivative parts can be processed individually and merged back into the original batch.

Package metadata contains implementations of types.Metadata.

Package roundtrip provides tooling for composing request/response behaviour through messages.

Package tracing implements utility functions for recording opentracing events for messages.

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

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.

GetAllBytesLen returns total length of message content in bytes.

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

Lock wraps a message into a read only type that restricts access to only a single message part, accessible either by index 0 or -1.

MetaPartCopy creates a new empty message part by copying any meta fields (metadata, context, etc) from a reference part.

New initializes a new message from a 2D byte slice, the slice can be nil.

NewPart initializes a new message part.

SetAllMetadata sets the metadata of all message parts to match a provided metadata implementation.

ToBytes serialises a message into a single byte array.

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.

Errors returned by the message type.

Part is an implementation of types.Part, containing the contents and metadata of a message part.

Type is the standard implementation of types.Message, containing a multiple part message.