indexer

Documentation

Index

• Variables
• type Indexer
  • func NewIndexer(pool table.Client, mf metrics.Factory, logger *zap.Logger, ...) *Indexer
  • func (w *Indexer) Add(span *model.Span) error
  • func (w *Indexer) Close()
• type Options

Variables

var ErrOverflow = errors.New("indexer buffer overflow")

Types

type Indexer

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

func NewIndexer

func NewIndexer(pool table.Client, mf metrics.Factory, logger *zap.Logger, jaegerLogger hclog.Logger, opts Options) *Indexer

func (*Indexer) Add

func (w *Indexer) Add(span *model.Span) error

func (*Indexer) Close

func (w *Indexer) Close()

type Options

type Options struct {
	DbPath              schema.DbPath
	MaxTraces           int
	MaxTTL              time.Duration
	BufferSize          int
	Batch               batch.Options
	WriteTimeout        time.Duration
	RetryAttemptTimeout time.Duration
}