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 input.Streamed, log log.Modular) input.Streamed + type Impl struct + func (m *Impl) Connected() bool + func (m *Impl) TransactionChan() <-chan message.Transaction + func (m *Impl) TriggerCloseNow() + func (m *Impl) TriggerStopConsuming() + func (m *Impl) WaitForClose(ctx context.Context) error
Go to main page