Package config contains reusable config definitions and parsers for inputs defined via the public/service package.

AsyncReaderWithConnBackOff set the backoff used for limiting connection attempts.

NewAsyncCutOff returns a new AsyncCutOff wrapper around a input.Async.

NewAsyncPreserver returns a new AsyncPreserver wrapper around a input.Async.

NewAsyncReader creates a new AsyncReader input type.

NewConfig returns a configuration struct fully populated with default values.

WrapWithPipeline routes an input directly into a processing pipeline and returns a type that manages both and acts like an ordinary input.

WrapWithPipelines wraps an input with a variadic number of pipelines.

AsyncCutOff is a wrapper for input.Async implementations that exits from WaitForClose immediately.

AsyncPreserver is a wrapper for input.Async implementations that keeps a buffer of sent messages until they are acknowledged.

AsyncReader is an input implementation that reads messages from an input.Async component.

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

WithPipeline is a type that wraps both an input type and a pipeline type by routing the input through the pipeline, and implements the input.Type interface in order to act like an ordinary input.

Async is a type that reads Bento messages from an external source and allows acknowledgements for a message batch to be propagated asynchronously.

Streamed is a common interface implemented by inputs and provides channel based streaming APIs.

AsyncAckFn is a function used to acknowledge receipt of a message batch.