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 IterateBatchedSend(msg message.Batch, fn func(int, *message.Part) error) error + type AsyncSink interface + Close func(ctx context.Context) error + Connect func(ctx context.Context) error + WriteBatch func(ctx context.Context, msg message.Batch) error + type AsyncWriter struct + func (w *AsyncWriter) Connected() bool + func (w *AsyncWriter) Consume(ts <-chan message.Transaction) error + func (w *AsyncWriter) TriggerCloseNow() + func (w *AsyncWriter) WaitForClose(ctx context.Context) error + type Config struct + Label string + Plugin any + Processors []processor.Config + Type string + func FromAny(prov docs.Provider, value any) (conf Config, err error) + func NewConfig() Config + type Streamed interface + Connected func() bool + Consume func(<-chan message.Transaction) error + TriggerCloseNow func() + WaitForClose func(ctx context.Context) error + func NewAsyncWriter(typeStr string, maxInflight int, w AsyncSink, mgr component.Observability) (Streamed, error) + func OnlySinglePayloads(out Streamed) Streamed + func WrapWithPipelines(out Streamed, pipeConstructors ...iprocessor.PipelineConstructorFunc) (Streamed, error) + type Sync interface + Connected func() bool + TriggerCloseNow func() + TriggerStopConsuming func() + WaitForClose func(ctx context.Context) error + WriteTransaction func(context.Context, message.Transaction) error + type WithPipeline struct + func WrapWithPipeline(out Streamed, pipeConstructor iprocessor.PipelineConstructorFunc) (*WithPipeline, error) + func (i *WithPipeline) Connected() bool + func (i *WithPipeline) Consume(tsChan <-chan message.Transaction) error + func (i *WithPipeline) TriggerCloseNow() + func (i *WithPipeline) WaitForClose(ctx context.Context) error
Go to main page