trace

type Batch ¶

type Batch struct {
	// contains filtered or unexported fields
}

Batch individual insertTracesReq.

func NewBatch(maxBatchSize int) *Batch

type Batcher ¶

type Batcher struct {
	// contains filtered or unexported fields
}

Batcher batches trace requests and sends batches to batch writer. This is done to achieve better ingest performance especially b/c Jaeger collector sends traces one by one.

func NewBatcher(config BatcherConfig, writer Writer) *Batcher

func (b *Batcher) Run()

func (b *Batcher) Stop()

type BatcherConfig ¶

type BatcherConfig struct {
	Batchers     int
	Writers      int
	MaxBatchSize int
	BatchTimeout time.Duration
}

type Dispatcher ¶

type Dispatcher struct {
	// contains filtered or unexported fields
}

Dispatcher manages trace batcher and ingestion Dispatches user request which are combined into batches later on

func NewDispatcher(writer Writer, async bool, batchConfig BatcherConfig) *Dispatcher

func (td *Dispatcher) Close()

func (td *Dispatcher) InsertTraces(ctx context.Context, traces ptrace.Traces) (err error)

type TagType ¶

type TagType uint

const (
	SpanTagType TagType = 1 << iota
	ResourceTagType
	EventTagType
	LinkTagType
)

type Writer ¶

type Writer interface {
	InsertTraces(ctx context.Context, traces ptrace.Traces) error
	Close()
}