writer

package
v1.9.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 15, 2024 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ArchiveSpanWriter

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

func NewArchiveWriter

func NewArchiveWriter(pool table.Client, factory metrics.Factory, logger *zap.Logger, jaegerLogger hclog.Logger, opts BatchWriterOptions) *ArchiveSpanWriter

func (*ArchiveSpanWriter) WriteItems

func (w *ArchiveSpanWriter) WriteItems(items []interface{})

type BatchSpanWriter

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

func NewBatchWriter

func NewBatchWriter(pool table.Client, factory metrics.Factory, logger *zap.Logger, jaegerLogger hclog.Logger, opts BatchWriterOptions) *BatchSpanWriter

func (*BatchSpanWriter) WriteItems

func (w *BatchSpanWriter) WriteItems(items []interface{})

type BatchWriterOptions

type BatchWriterOptions struct {
	DbPath              schema.DbPath
	WriteTimeout        time.Duration
	RetryAttemptTimeout time.Duration
}

type SpanWriter

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

SpanWriter handles all span/indexer writes to YDB

func NewSpanWriter

func NewSpanWriter(pool table.Client, metricsFactory metrics.Factory, logger *zap.Logger, jaegerLogger hclog.Logger, opts SpanWriterOptions) *SpanWriter

NewSpanWriter creates writer interface implementation for YDB

func (*SpanWriter) Close

func (s *SpanWriter) Close()

func (*SpanWriter) WriteSpan

func (s *SpanWriter) WriteSpan(ctx context.Context, span *model.Span) error

WriteSpan saves the span into YDB

type SpanWriterOptions

type SpanWriterOptions struct {
	BufferSize          int
	BatchSize           int
	BatchWorkers        int
	IndexerBufferSize   int
	IndexerMaxTraces    int
	IndexerTTL          time.Duration
	DbPath              schema.DbPath
	WriteTimeout        time.Duration
	RetryAttemptTimeout time.Duration
	ArchiveWriter       bool
	OpCacheSize         int
	MaxSpanAge          time.Duration
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL