writer

Documentation

Index

• type ArchiveSpanWriter
  • func NewArchiveWriter(pool table.Client, factory metrics.Factory, logger *zap.Logger, ...) *ArchiveSpanWriter
  • func (w *ArchiveSpanWriter) WriteItems(items []interface{})
• type BatchSpanWriter
  • func NewBatchWriter(pool table.Client, factory metrics.Factory, logger *zap.Logger, ...) *BatchSpanWriter
  • func (w *BatchSpanWriter) WriteItems(items []interface{})
• type BatchWriterOptions
• type SpanWriter
  • func NewSpanWriter(pool table.Client, metricsFactory metrics.Factory, logger *zap.Logger, ...) *SpanWriter
  • func (s *SpanWriter) Close()
  • func (s *SpanWriter) WriteSpan(ctx context.Context, span *model.Span) error
• type SpanWriterOptions

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
}