batcher

package
v4.14.1 Latest Latest
Warning

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

Go to latest
Published: Apr 26, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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) Connected

func (m *Impl) Connected() bool

Connected returns a boolean indicating whether this output is currently connected to its target.

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.

Jump to

Keyboard shortcuts

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