sdklog

type BatchLogProcessorOption func(o *BatchLogProcessorOptions)

type BatchLogProcessorOptions struct {
	// MaxQueueSize is the maximum queue size to buffer spans for delayed processing. If the
	// queue gets full it drops the spans. Use BlockOnQueueFull to change this behavior.
	// The default value of MaxQueueSize is 2048.
	MaxQueueSize int

	// BatchTimeout is the maximum duration for constructing a batch. Processor
	// forcefully sends available spans when timeout is reached.
	// The default value of BatchTimeout is 5000 msec.
	BatchTimeout time.Duration

	// ExportTimeout specifies the maximum duration for exporting spans. If the timeout
	// is reached, the export will be cancelled.
	// The default value of ExportTimeout is 30000 msec.
	ExportTimeout time.Duration

	// MaxExportBatchSize is the maximum number of spans to process in a single batch.
	// If there are more than one batch worth of spans then it processes multiple batches
	// of spans one batch after the other without any delay.
	// The default value of MaxExportBatchSize is 512.
	MaxExportBatchSize int

	// BlockOnQueueFull blocks onEnd() and onStart() method if the queue is full
	// AND if BlockOnQueueFull is set to true.
	// Blocking option should be used carefully as it can severely affect the performance of an
	// application.
	BlockOnQueueFull bool
}

type LogData struct {
	log.Record

	Resource             *resource.Resource
	InstrumentationScope instrumentation.Scope

	TraceID trace.TraceID
	SpanID  trace.SpanID
}

type LogExporter interface {
	ExportLogs(ctx context.Context, logs []*LogData) error
	Shutdown(ctx context.Context) error
}

type LogProcessor interface {
	OnEmit(context.Context, *LogData)
	Shutdown(context.Context) error
}

type LoggerProvider struct {
	embedded.LoggerProvider
	// contains filtered or unexported fields
}