Versions in this module Expand all Collapse all v1 v1.0.2 Mar 22, 2024 v1.0.1 Nov 9, 2023 Changes in this version + const DefaultBatchTimeout + const DefaultBlockOnQueueFull + const DefaultMaxBatchedPacketSize + const DefaultMaxExportBatchSize + const DefaultMaxQueueSize + func NewBatchCore(syncer *BatchWriteSyncer, opts ...sdklog.LoggerOption) zapcore.Core + func NewBatchCoreAndLevel(syncer *BatchWriteSyncer, opts ...sdklog.LoggerOption) (zapcore.Core, zap.AtomicLevel) + func NewCore(opts ...sdklog.LoggerOption) zapcore.Core + func NewEncoder(cfg zapcore.EncoderConfig) zapcore.Encoder + func NewJSONCore() zapcore.Core + func NewJSONWriteSyncer() zapcore.WriteSyncer + func NewWriteSyncer(p *sdklog.BatchProcessor, rs *resource.Resource) zapcore.WriteSyncer + type BatchSyncerOption func(o *BatchSyncerOptions) + func WithBatchTimeout(delay time.Duration) BatchSyncerOption + func WithBlocking() BatchSyncerOption + func WithEnableSampler(enableSampler bool) BatchSyncerOption + func WithEnableSamplerError(enableSamplerError bool) BatchSyncerOption + func WithMaxExportBatchSize(size int) BatchSyncerOption + func WithMaxPacketSize(size int) BatchSyncerOption + func WithMaxQueueSize(size int) BatchSyncerOption + type BatchSyncerOptions struct + BatchTimeout time.Duration + BlockOnQueueFull bool + EnableSampler bool + EnableSamplerError bool + MaxExportBatchSize int + MaxPacketSize int + MaxQueueSize int + type BatchWriteSyncer struct + func NewBatchWriteSyncer(exporter sdklog.Exporter, rs *resource.Resource, opts ...BatchSyncerOption) *BatchWriteSyncer + func (bp *BatchWriteSyncer) Enqueue(sl *logsproto.ScopeLogs, size int) + func (bp *BatchWriteSyncer) Sync() error + func (bp *BatchWriteSyncer) Write(p []byte) (n int, err error)
Go to main page