stanza

May 12, 2022

Changes in this version

+ func ConvertFrom(pLogs plog.Logs) []*entry.Entry

+ func GetPersister(storageClient storage.Client) operator.Persister

+ func GetStorageClient(ctx context.Context, id config.ComponentID, componentKind component.Kind, ...) (storage.Client, error)

type BaseConfig

+ func (cfg BaseConfig) DecodeOperatorConfigs() ([]operator.Config, error)

+ type FromPdataConverter struct

+ func NewFromPdataConverter(workerCount int, logger *zap.Logger) *FromPdataConverter

+ func (c *FromPdataConverter) Batch(pLogs plog.Logs) error

+ func (c *FromPdataConverter) OutChannel() <-chan []*entry.Entry

+ func (c *FromPdataConverter) Start()

+ func (c *FromPdataConverter) Stop()

type LogEmitter

+ func (e *LogEmitter) OutChannel() <-chan []*entry.Entry

Mar 2, 2022

Changes in this version

+ func HashResource(resource map[string]interface{}) uint64

Dec 9, 2021

Changes in this version

type LogEmitter

+ func (e *LogEmitter) Start(_ operator.Persister) error

+ type LogEmitterOption func(*LogEmitter)

+ func LogEmitterWithFlushInterval(flushInterval time.Duration) LogEmitterOption

+ func LogEmitterWithLogger(logger *zap.SugaredLogger) LogEmitterOption

+ func LogEmitterWithMaxBatchSize(maxBatchSize uint) LogEmitterOption

May 18, 2021

Changes in this version

type ConverterConfig

+ WorkerCount int

type ConverterOption

+ func WithWorkerCount(workerCount int) ConverterOption

Apr 20, 2021

Changes in this version

+ const DefaultFlushInterval

+ const DefaultMaxFlushCount

type BaseConfig

+ Converter ConverterConfig

+ type Converter struct

+ func NewConverter(opts ...ConverterOption) *Converter

+ func (c *Converter) Batch(e *entry.Entry) error

+ func (c *Converter) OutChannel() <-chan pdata.Logs

+ func (c *Converter) Start()

+ func (c *Converter) Stop()

+ type ConverterConfig struct

+ FlushInterval time.Duration

+ MaxFlushCount uint

+ type ConverterOption interface

+ func WithFlushInterval(interval time.Duration) ConverterOption

+ func WithLogger(logger *zap.Logger) ConverterOption

+ func WithMaxFlushCount(count uint) ConverterOption

Feb 24, 2021

Changes in this version

+ func Convert(obsLog *entry.Entry) pdata.Logs

+ func NewFactory(logReceiverType LogReceiverType) component.ReceiverFactory

+ type BaseConfig struct

+ Operators OperatorConfigs

+ type InputConfig map[string]interface

+ type LogEmitter struct

+ func NewLogEmitter(logger *zap.SugaredLogger) *LogEmitter

+ func (e *LogEmitter) Process(ctx context.Context, ent *entry.Entry) error

+ func (e *LogEmitter) Stop() error

+ type LogReceiverType interface

+ BaseConfig func(configmodels.Receiver) BaseConfig

+ CreateDefaultConfig func() configmodels.Receiver

+ DecodeInputConfig func(configmodels.Receiver) (*operator.Config, error)

+ Type func() configmodels.Type

+ type OperatorConfigs []map[string]interface