Struct RuntimeOptions 

pub struct RuntimeOptions {
    pub handle_signals: bool,
    pub max_records: usize,
    pub poll_timeout: Duration,
    pub idle_flush: Duration,
    pub blocked_retry: Duration,
    pub event_poll_timeout: Duration,
    pub version: String,
    pub dead_letter_read_interval: Option<Duration>,
}

Knobs that are not part of the user-facing YAML (loop granularities, test hooks). The defaults suit production; tests shrink the timings.

Fields

handle_signals: bool

Install SIGTERM/SIGINT handlers that trigger a graceful drain. Disable in tests and drive ShutdownHandle instead.

max_records: usize

Max payloads per lane poll.

poll_timeout: Duration

Lane poll timeout (also the paused/idle loop sleep).

idle_flush: Duration

Flush the chain after this long without new data.

blocked_retry: Duration

Sleep between retries of a blocked batch.

event_poll_timeout: Duration

Controller poll_events timeout.

version: String

Version string published on spate_pipeline_info.

dead_letter_read_interval: Option<Duration>

How often to read the depth of the feed’s dead-letter destination for spate_feed_dead_letter_units, starting at startup. A zero interval reads whenever no read is pending. None makes no such read, so every depth read the feed answers is its source’s.

Trait Implementations

impl Clone for RuntimeOptions

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 RuntimeOptions

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

Formats the value using the given formatter.

impl Default for RuntimeOptions

fn default() -> Self

Returns the “default value” for a type.