Struct SubscriptionConfig 

pub struct SubscriptionConfig {
    pub buffer_size: usize,
    pub backpressure: BackpressureStrategy,
    pub filter: Option<String>,
    pub send_snapshot: bool,
    pub max_batch_size: usize,
    pub max_batch_delay_us: u64,
}

Configuration for a subscription.

Fields

buffer_size: usize

Channel buffer capacity.

backpressure: BackpressureStrategy

Backpressure strategy when buffer is full.

filter: Option<String>

Optional filter predicate (evaluated in Ring 1).

send_snapshot: bool

Whether to send an initial snapshot on subscribe.

max_batch_size: usize

Maximum batch size for delivery.

max_batch_delay_us: u64

Maximum batch delay before flushing (microseconds).

Trait Implementations

impl Clone for SubscriptionConfig

fn clone(&self) -> SubscriptionConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionConfig

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

Formats the value using the given formatter.

impl Default for SubscriptionConfig

fn default() -> Self

Returns the “default value” for a type.