# Functions
NewBatchError creates a fresh batch error from a general error message.
NewTransaction creates a new transaction object from a message payload and a response channel.
NoopMgr returns a Manager implementation that does nothing.
# Variables
ErrAlreadyStarted is returned when an input or output type gets started a second time.
Errors used throughout the codebase.
Errors used throughout the codebase.
Manager errors.
Errors used throughout the codebase.
Manager errors.
Manager errors.
Errors used throughout the codebase.
Errors used throughout the codebase.
Errors used throughout the codebase.
Errors used throughout the codebase.
Errors used throughout the codebase.
Errors used throughout the codebase.
Errors used throughout the codebase.
Errors used throughout the codebase.
Errors used throughout the codebase.
Manager errors.
Manager errors.
Errors used throughout the codebase.
Buffer errors.
Errors used throughout the codebase.
Errors used throughout the codebase.
Manager errors.
Manager errors.
Manager errors.
Manager errors.
Manager errors.
Errors used throughout the codebase.
Errors used throughout the codebase.
FailFlagKey is a metadata key used for flagging processor errors in Benthos.
# Structs
BatchError represents a general error across an entire batch of messages that can optionally be broken down into errors at the individual message level, identified by their index in the batch.
CacheTTLItem contains a value to cache along with an optional TTL.
DudMgr is a noop implementation of a types.Manager.
ErrUnexpectedHTTPRes is an error returned when an HTTP request returned an unexpected response.
HTTPMessage is a struct containing a benthos message, to be sent over the wire in an HTTP request.
HTTPResponse is a struct expected as an HTTP response after sending a message.
Transaction is a type respesenting a transaction containing a payload (the message) and a response channel, which is used to indicate whether the message was successfully propagated to the next destination.
# Interfaces
Cache is a key/value store that can be shared across components and executing threads of a Benthos service.
CacheWithTTL is a key/value store that can be shared across components and executing threads of a Benthos service.
Closable defines a type that can be safely closed down and cleaned up.
Condition reads a message, calculates a condition and returns a boolean.
Consumer is the higher level consumer type.
Input is a closable Producer.
Manager is an interface expected by Benthos components that allows them to register their service wide behaviours such as HTTP endpoints and event listeners, and obtain service wide shared resources such as caches.
Message is an interface representing a payload of data that was received from an input.
Metadata is an interface representing the metadata of a message part within a batch.
Output is a closable Consumer.
OutputWriter is a non-channel based output interface.
Part is an interface representing a message part.
Pipeline is an interface that implements both the Consumer and Producer interfaces, and can therefore be used to pipe messages from Producer to a Consumer.
Processor reads a message, performs some form of data processing to the message, and returns either a slice of >= 1 resulting messages or a response to return to the message origin.
Producer is a type that sends messages as transactions and waits for a response back, the response indicates whether the message was successfully propagated to a new destination (and can be discarded from the source.).
RateLimit is a strategy for limiting access to a shared resource, this strategy can be safely used by components in parallel.
Response is a response from an output, agent or broker that confirms the input of successful message receipt.
# Type aliases
PipelineConstructorFunc is a constructor to be called for each parallel stream pipeline thread in order to construct a custom pipeline implementation.
ProcessorConstructorFunc is a constructor to be called for each parallel stream pipeline thread in order to construct a custom processor implementation.