Module source_sender 

Structs

Builder

SourceSender

SourceSenderItem

SourceSenderItem is a thin wrapper around EventArray used to track the send duration of a batch.

Enums

SendError

Constants

DEFAULT_CHUNK_SIZE_EVENTS

Default number of events batched per source send, and the base used for source output buffer sizing. Used when the chunk size has not been configured at startup.

Traits

PostProcessor

A post-processing step applied to every event that flows through a SourceSender.

Functions

chunk_size_events

Returns the configured source sender chunk size in events, or DEFAULT_CHUNK_SIZE_EVENTS if unset.

set_chunk_size_events

Sets the process-wide source sender chunk size in events. Must be called at most once, before the topology is built. Panics if called more than once.