AddCompressFunc adds a compression algorithm to components.

AddDecompressFunc adds a decompression algorithm to components.

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.

CacheWriter implements an output writer for caches.

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.

CompressFunc represents a compression algorithm and fully encapsulates it.

DecompressFunc represents a decompression algorithm and fully encapsulates it.