CopyLogBuffer duplicates the given buffer of log records, for passing into channel.

NewLogParsingReceiver creates a MultiSinkMessageReceiver to parse incoming logs, buffer them and pass to a buffer receiver Actual parsers are created on demand for each of connections.

NewLogProcessingWorker creates LogProcessingWorker.

NewPipelineWorkerBase creates a new PipelineWorkerBase for specified data type in channel.

NewRewritersFromConfig creates rewriters from a list of rewriter configurations and returns the head.

NewSyslogUnescaper creates an unescaper for syslog inputs Unescaping is logically part of input parsing but moved to transform and rewrite for performance reason.

NewTransformsFromConfig creates transforms from a list of transform configurations.

RunTransforms executes all the given transforms on a log record.

SumLogRecordsLength calculates the total of RawLength of given records.

VerifyInputConfigs verifies a list of input configurations.

VerifyRewriterConfigs verifies a list of rewriter configurations.

VerifyTransformConfigs verifies a list of transform configurations.

LogProcessingWorker is a worker for transformation, serialization and chunk making.

OutputInterface is a joint interface of output components.

PipelineWorkerBase is the base worker class for pipeline workers It contains an input channel, process function for each of input values, and "stop" signals which are triggered when input channel is closed The process function (PipelineProcFunc) is the only thing required from its composite parent.

LogParserConstructor represents a function to create new LogParser instances in LogParsingReceiver.