Convert converts one entry.Entry into plog.Logs.

ConvertFrom converts plog.Logs into a slice of entry.Entry To be used in a stateless setting like tests where ease of use is more important than performance or throughput.

HashResource will hash an entry.Entry.Resource.

LogEmitterWithFlushInterval returns an option that makes the LogEmitter use the specified flush interval.

LogEmitterWithLogger returns an option that makes the LogEmitter use the specified logger.

LogEmitterWithMaxBatchSize returns an option that makes the LogEmitter use the specified max batch size.

NewFactory creates a factory for a Stanza-based receiver.

NewLogEmitter creates a new receiver output.

BaseConfig is the common configuration of a stanza-based receiver.

Converter converts a batch of entry.Entry into plog.Logs aggregating translated entries into logs coming from the same Resource.

ConverterConfig controls how the internal entry.Entry to plog.Logs converter works.

FromPdataConverter converts a set of entry.Entry into plog.Logs The diagram below illustrates the internal communication inside the FromPdataConverter: ┌─────────────────────────────────┐ │ Batch() │ ┌─────────┤ Ingests plog.Logs, splits up │ │ │ and places them on workerChan │ │ └─────────────────────────────────┘ │ │ ┌───────────────────────────────────────────────────┐ ├─► workerLoop() │ │ │ ┌─────────────────────────────────────────────────┴─┐ ├─┼─► workerLoop() │ │ │ │ ┌─────────────────────────────────────────────────┴─┐ └─┼─┼─► workerLoop() │ └─┤ │ consumes sent log entries from workerChan, │ │ │ translates received logs to entry.Entry, │ └─┤ and sends them along entriesChan │ └───────────────────────────────────────────────────┘ .

LogEmitter is a stanza operator that emits log entries to a channel.

LogReceiverType is the interface used by stanza-based log receivers.

InputConfig is an alias that allows unmarshaling outside of mapstructure This is meant to be used only for the input operator.

OperatorConfigs is an alias that allows for unmarshaling outside of mapstructure Stanza operators should will be migrated to mapstructure for greater compatibility but this allows a temporary solution.