batcher

Documentation

Index

• func New(batcher *policy.Batcher, child input.Streamed, log log.Modular) input.Streamed
• type Impl
  • func (m *Impl) ConnectionStatus() component.ConnectionStatuses
  • func (m *Impl) TransactionChan() <-chan message.Transaction
  • func (m *Impl) TriggerCloseNow()
  • func (m *Impl) TriggerStopConsuming()
  • func (m *Impl) WaitForClose(ctx context.Context) error

Functions

func New

func New(batcher *policy.Batcher, child input.Streamed, log log.Modular) input.Streamed

New creates a new Batcher around an input.

Types

type Impl

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

Impl wraps an input with a batch 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) TransactionChan

func (m *Impl) TransactionChan() <-chan message.Transaction

TransactionChan returns the channel used for consuming messages from this buffer.

func (*Impl) TriggerCloseNow

func (m *Impl) TriggerCloseNow()

TriggerCloseNow triggers the shut down of this component but should not block the calling goroutine.

func (*Impl) TriggerStopConsuming

func (m *Impl) TriggerStopConsuming()

TriggerStopConsuming instructs the input to start shutting down resources once all pending messages are delivered and acknowledged. This call does not block.

func (*Impl) WaitForClose

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

WaitForClose is a blocking call to wait until the component has finished shutting down and cleaning up resources.