ungrouped

Documentation

Index

• type Batcher
  • func New(selector export.AggregationSelector, stateful bool) *Batcher
  • func (b *Batcher) AggregatorFor(descriptor *export.Descriptor) export.Aggregator
  • func (b *Batcher) CheckpointSet() export.CheckpointSet
  • func (b *Batcher) FinishedCollection()
  • func (b *Batcher) Process(_ context.Context, record export.Record) error

Types

type Batcher

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

func New

func New(selector export.AggregationSelector, stateful bool) *Batcher

func (*Batcher) AggregatorFor

func (b *Batcher) AggregatorFor(descriptor *export.Descriptor) export.Aggregator

func (*Batcher) CheckpointSet

func (b *Batcher) CheckpointSet() export.CheckpointSet

func (*Batcher) FinishedCollection

func (b *Batcher) FinishedCollection()

func (*Batcher) Process

func (b *Batcher) Process(_ context.Context, record export.Record) error