batcher

Apr 24, 2019

Changes in this version

+ func Split(n int, opts *Options) []int

+ type Options struct

+ MaxBatchSize int

+ MaxHandlers int

+ MinBatchSize int

Dec 13, 2018

Changes in this version

+ type Batcher struct

+ func New(itemType reflect.Type, maxHandlers int, handler func(interface{}) error) *Batcher

+ func (b *Batcher) Add(ctx context.Context, item interface{}) error

+ func (b *Batcher) AddNoWait(item interface{}) <-chan error

+ func (b *Batcher) Shutdown()