ExecuteAll attempts to execute a slice of processors to a message.

ExecuteCatchAll attempts to execute a slice of processors to only messages that have failed a processing step.

ExecuteTryAll attempts to execute a slice of processors to messages, if a message has failed a processing step it is prevented from being sent to subsequent processors.

MarkErr marks a message part as having failed.

NewAutoObservedBatchedProcessor wraps an AutoObservedBatched processor with an implementation of V1 which handles observability information.

NewAutoObservedProcessor wraps an AutoObserved processor with an implementation of V1 which handles observability information.

NewConfig returns a configuration struct fully populated with default values.

TestBatchProcContext creates a context for batch processors.

Unwrap attempts to access a wrapped processor from the provided implementation where applicable, otherwise the provided processor is returned.

BatchProcContext provides methods for triggering observability updates and accessing processor specific spans.

Config is the all encompassing configuration struct for all processor types.

AutoObserved is a simpler processor interface to implement than V1 as it is not required to emit observability information within the implementation itself.

AutoObservedBatched is a simpler processor interface to implement than V1 as it is not required to emit observability information within the implementation itself.

Pipeline is an interface that implements channel based consumer and producer methods for streaming data through a processing pipeline.

V1 is a common interface implemented by processors.

PipelineConstructorFunc is a constructor to be called for each parallel stream pipeline thread in order to construct a custom pipeline implementation.