Struct SourceConfig 

pub struct SourceConfig {
    pub channel: ChannelConfig,
    pub name: Option<String>,
    pub max_queued_bytes: usize,
}

Configuration for a Source.

Fields

channel: ChannelConfig

Channel configuration.

name: Option<String>

Name of the source (for debugging/metrics).

max_queued_bytes: usize

Arrow-byte limit shared by cloned producers, the input ring and queued broadcast data. Defaults to 64 MiB. Generic Record<T> pushes remain count bounded; their arbitrary heap storage is not measured. Invalid limits make push_arrow return InvalidConfig.

Implementations

impl SourceConfig

pub fn with_buffer_size(buffer_size: usize) -> Self

Creates a source config with the specified buffer size.

pub fn named(name: impl Into<String>) -> Self

Creates a named source config.

Trait Implementations

impl Clone for SourceConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SourceConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SourceConfig

fn default() -> Self

Returns the “default value” for a type.