Versions in this module Expand all Collapse all v4 v4.22.0 Oct 23, 2023 Changes in this version + func FieldSpec() docs.FieldSpec + type Batcher struct + func New(conf batchconfig.Config, mgr bundle.NewManagement) (*Batcher, error) + func (p *Batcher) Add(part *message.Part) bool + func (p *Batcher) Close(ctx context.Context) error + func (p *Batcher) Count() int + func (p *Batcher) Flush(ctx context.Context) message.Batch + func (p *Batcher) UntilNext() time.Duration
Go to main page