Load uses a Config object to create a new complete Pipeline instance with configured queue and outputs.

LoadWithSettings is the same as Load, but it exposes a Settings object that includes processors and WaitClose behavior.

New create a new Pipeline instance from a queue instance and a set of outputs.

NewNilPipeline returns a new pipeline that is compatible with beats.PipelineConnector.

NewSyncClient creates a new sync clients from the provided configuration, existing ACKs handlers defined in the configuration will be proxied by this object.

NoWaitOnClose disable wait close in the pipeline.

WaitOnClientClose applies WaitClose timeout to each client connecting to the pipeline.

WaitOnPipelineClose applies WaitClose to the pipeline itself, waiting for outputs to ACK any outstanding events.

Config object for loading a pipeline instance via Load.

Monitors configures visibility for observing state and progress of the pipeline.

Pipeline implementation providint all beats publisher functionality.

Settings is used to pass additional settings to a newly created pipeline instance.

SyncClient wraps an existing beat.Client and provide a sync interface.

Client implements the interface used by all the functionbeat function, we only implement a synchronous client.

OutputReloader interface, that can be queried from an active publisher pipeline.

OutputFactory is used by the publisher pipeline to create an output instance.

WaitCloseMode enumerates the possible behaviors of WaitClose in a pipeline.