Versions in this module Expand all Collapse all v0 v0.2.0 May 25, 2022 Changes in this version + type Batcher struct + func New(exporter klogga.Exporter, conf Config) *Batcher + func (b *Batcher) ErredCount() (res uint64) + func (b *Batcher) FlushedCount() (res uint64) + func (b *Batcher) Shutdown(ctx context.Context) (err error) + func (b *Batcher) TriggerFlush() + func (b *Batcher) Write(ctx context.Context, spans []*klogga.Span) error + type Config struct + BatchSize int + BufferSize int + Timeout time.Duration + func ConfigDefault() Config + func (c *Config) GetBatchSize() int + func (c *Config) GetBufferSize() int + type DelayDrop struct + Count atomic.Int32 + Delay time.Duration + func (n *DelayDrop) Shutdown(context.Context) error + func (n *DelayDrop) Write(ctx context.Context, spans []*klogga.Span) error
Go to main page