batcher

Documentation

Index

• type Batcher
  • func (b *Batcher[T]) Run(in <-chan T, flushFn func(buf []T))

Types

type Batcher

type Batcher[T any] struct {
	Buffer   int           `mapstructure:"batch_buffer"`
	Interval time.Duration `mapstructure:"batch_interval"`
}

batcher is a helper for cases when plugin needs to send events in batches it passes a batch of events to passed func when: - buffer is full - ticker ticks - input chanel is closed and readed to the end

batcher clears buffer after each call of flushFn()

func (*Batcher[T]) Run

func (b *Batcher[T]) Run(in <-chan T, flushFn func(buf []T))