batcher

Documentation

Index

• func New(batcher *policy.Batcher, child input.Streamed, log log.Modular, ...) input.Streamed
• type Impl
  • func (m *Impl) CloseAsync()
  • func (m *Impl) Connected() bool
  • func (m *Impl) TransactionChan() <-chan message.Transaction
  • func (m *Impl) WaitForClose(timeout time.Duration) error

Functions

func New

func New(batcher *policy.Batcher, child input.Streamed, log log.Modular, stats metrics.Type) 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) CloseAsync

func (m *Impl) CloseAsync()

CloseAsync shuts down the Batcher and stops processing messages.

func (*Impl) Connected

func (m *Impl) Connected() bool

Connected returns true if the underlying input is connected.

func (*Impl) TransactionChan

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

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

func (*Impl) WaitForClose

func (m *Impl) WaitForClose(timeout time.Duration) error

WaitForClose blocks until the Batcher output has closed down.