batcher

package
v4.4.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 19, 2022 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL