NewCacheWriter creates a writer for cache the output plugin.

NewWorkflow instanciates a new workflow processor.

RetryOutputIndefinitely returns a wrapped variant of the provided output where send errors downstream are automatically caught and retried rather than propagated upstream as nacks.

SwitchReorderFromGroup takes a message sort group and rearranges a slice of message parts so that they match up from their origins.

ErrBrokerNoInputs is returned when creating a broker with zero inputs.

ErrBrokerNoOutputs is returned when creating a Broker type with zero outputs.

ErrSwitchNoCasesMatched is returned when a message does not match any output cases.

ErrSwitchNoConditionMet is returned when a message does not match any output conditions.

ErrSwitchNoOutputs is returned when creating a switchOutput type with less than 2 outputs.

Branch contains conditions and maps for transforming a batch of messages into a subset of request messages, and mapping results from those requests back into the original message batch.

The Primary is read from and closed second.

The Primary is written to and closed first.

SyncResponseWriter is a writer implementation that adds messages to a ResultStore located in the context of the first message part of each batch.

Workflow is a processor that applies a list of child processors to a new payload mapped from the original, and after processing attempts to overlay the results back onto the original payloads according to more mappings.