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) ConnectionTest(ctx context.Context) component.ConnectionTestResults
- func (m *Impl) Consume(msgs <-chan message.Transaction) error
- func (m *Impl) TriggerCloseNow()
- func (m *Impl) TriggerStartConsuming()
- func (m *Impl) WaitForClose(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
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 ¶ added in v4.31.0
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) ConnectionTest ¶ added in v4.63.0
func (m *Impl) ConnectionTest(ctx context.Context) component.ConnectionTestResults
ConnectionTest attempts to establish whether the component is capable of creating a connection. This will potentially require and test network connectivity, but does not require the component to be initialized.
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) TriggerStartConsuming ¶ added in v4.63.0
func (m *Impl) TriggerStartConsuming()
TriggerStartConsuming initiates async connection and consumption.
Source Files