NewStageFiltering is a StageFiltering constructor.

NewStageJSONMarshalling is a constructor for StageJSONMarshalling.

NewStageParsingEntry is a StageParsingEntry constructor.

NewStageParsingSLI is a StageParsingSLI.

NewStageTransport is a StageTransport constructor.

StageInit initializes parallelism count of stage workers, then waits for stage to close.

SleepTransportUnavailable is used to determine how long to sleep between deliver attempts.

StageFiltering filters messages from input.

StageJSONMarshalling marshals messages from input to JSON and sends them to output.

StageParsingEntry parses lines using given parser, extends resulting map with metadata and sends it downstream.

StageParsingSLI checks if the message in its input is a SLI message, modifies metrics, then sends message downstream.

StageTransport stacks messages from input into batches and tries to send them to transport.

MetricsCollector is a metrics counter object interface for parsing sli stage.

ParserSLI may inject additional operations on parsed entry.

Stage interface.

TransportClient is a transport interface for transport stage.