batch

Nov 22, 2023

Changes in this version

type Batcher

+ func (f *Batcher[IN, OUT]) Enter(entry Entry[IN, OUT])

+ func (f *Batcher[IN, OUT]) EnterAndWait(entry Entry[IN, OUT])

Nov 15, 2023

Changes in this version

+ type Batcher struct

+ func NewBatcher[IN, OUT any](f Func[IN, OUT], tagID string, opt ...Option) *Batcher[IN, OUT]

+ type Entry interface

+ Callback func(out OUT)

+ Value func() IN

+ func NewEntry[IN, OUT any](v IN, callbackFn func(out OUT)) Entry[IN, OUT]

+ type Func func(targetID string, entries []Entry[IN, OUT])

+ type MultiBatcher struct

+ func NewMulti[IN, OUT any](f Func[IN, OUT], opt ...Option) *MultiBatcher[IN, OUT]

+ func (fp *MultiBatcher[IN, OUT]) Enter(targetID string, entry Entry[IN, OUT])

+ func (fp *MultiBatcher[IN, OUT]) EnterAndWait(targetID string, entry Entry[IN, OUT])

+ type NA = struct

+ type Option func(*config)

+ func WithBatchSize(batchSize int32) Option

+ func WithMaxWorkers(maxWorkers int32) Option

+ func WithMinWaitTime(minWaitTime time.Duration) Option