package
0.0.0-20240701064118-96e69a6460fb
Repository: https://github.com/relex/slog-agent.git
Documentation: pkg.go.dev
# Functions
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.
# Structs
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.
# Type aliases
LogParserConstructor represents a function to create new LogParser instances in LogParsingReceiver.