AddKnownCompressionAlgorithm registers a compression algorithm.

CacheOutputSpec returns the config spec of the cache output plugin.

CompressionAlgsList returns the list of registered compression algorithms.

DecompressionAlgsList returns the list of registered decompression algorithms.

NewCacheWriter creates a writer for the cache output plugin.

NewWorkflow instantiates 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 is a writer implementation for the cache output plugin.

CombinedReadCloser combines a Primary destination and a Source.

CombinedWriteCloser combines a Primary source and a Sink.

KnownCompressionAlgorithm is a unified interface for various compression algorithms.

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.