Versions in this module Expand all Collapse all v4 v4.27.1 May 31, 2024 v4.27.0 May 31, 2024 Changes in this version + func New(batcher *policy.Batcher, child output.Streamed, mgr bundle.NewManagement) output.Streamed + func NewFromConfig(conf batchconfig.Config, child output.Streamed, mgr bundle.NewManagement) (output.Streamed, error) + type Impl struct + func (m *Impl) Connected() bool + func (m *Impl) Consume(msgs <-chan message.Transaction) error + func (m *Impl) TriggerCloseNow() + func (m *Impl) WaitForClose(ctx context.Context) error
Go to main page