Versions in this module Expand all Collapse all v0 v0.17.1 Oct 26, 2019 Changes in this version + func Split(n int, opts *Options) []int + type Batcher struct + func New(itemType reflect.Type, opts *Options, 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() + type Options struct + MaxBatchSize int + MaxHandlers int + MinBatchSize int
Go to main page