Versions in this module Expand all Collapse all v0 v0.24.1 Jan 27, 2022 Changes in this version + var ErrMessageTooLarge = errors.New("batcher: message too large") + 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 + MaxBatchByteSize int + MaxBatchSize int + MaxHandlers int + MinBatchSize int