batcher

Documentation

Index

• 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
  • func (m *Impl) ConnectionStatus() component.ConnectionStatuses
  • func (m *Impl) Consume(msgs <-chan message.Transaction) error
  • func (m *Impl) TriggerCloseNow()
  • func (m *Impl) WaitForClose(ctx context.Context) error

Functions

func New

func New(batcher *policy.Batcher, child output.Streamed, mgr bundle.NewManagement) output.Streamed

New creates a new output preceded by a batching mechanism that enforces a given batching policy.

func NewFromConfig

func NewFromConfig(conf batchconfig.Config, child output.Streamed, mgr bundle.NewManagement) (output.Streamed, error)

NewFromConfig creates a new output preceded by a batching mechanism that enforces a given batching policy configuration.

Types

type Impl

type Impl struct {
	// contains filtered or unexported fields
}

Impl wraps an output with a batching policy.

func (*Impl) ConnectionStatus

func (m *Impl) ConnectionStatus() component.ConnectionStatuses

ConnectionStatus returns the current status of the given component connection. The result is a slice in order to accommodate higher order components that wrap several others.

func (*Impl) Consume

func (m *Impl) Consume(msgs <-chan message.Transaction) error

Consume assigns a messages channel for the output to read.

func (*Impl) TriggerCloseNow

func (m *Impl) TriggerCloseNow()

TriggerCloseNow shuts down the Batcher and stops processing messages.

func (*Impl) WaitForClose

func (m *Impl) WaitForClose(ctx context.Context) error

WaitForClose blocks until the Batcher output has closed down.