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 + type AckFunc func(context.Context, error) error + type Config struct + Plugin any + Type string + func FromAny(prov docs.Provider, value any) (conf Config, err error) + func NewConfig() Config + type ReaderWriter interface + Close func(context.Context) error + EndOfInput func() + Read func(context.Context) (message.Batch, AckFunc, error) + Write func(context.Context, message.Batch, AckFunc) error + type Stream struct + func (m *Stream) Consume(msgs <-chan message.Transaction) error + func (m *Stream) TransactionChan() <-chan message.Transaction + func (m *Stream) TriggerCloseNow() + func (m *Stream) TriggerStopConsuming() + func (m *Stream) WaitForClose(ctx context.Context) error + type Streamed interface + Consume func(<-chan message.Transaction) error + TransactionChan func() <-chan message.Transaction + TriggerCloseNow func() + TriggerStopConsuming func() + WaitForClose func(ctx context.Context) error + func NewStream(typeStr string, buffer ReaderWriter, mgr component.Observability) Streamed
Go to main page