batcher

Aug 4, 2015

Changes in this version

+ var ErrDisposed = errors.New("batcher: disposed")

+ type Batcher interface

+ Dispose func()

+ Flush func() error

+ Get func() ([]interface{}, error)

+ IsDisposed func() bool

+ Put func(interface{}) error

+ func New(maxTime time.Duration, maxItems, maxBytes, queueLen uint, ...) (Batcher, error)

+ type CalculateBytes func(interface{}) uint