Struct ChangeStreamConfig 

pub struct ChangeStreamConfig {
    pub pipeline: Vec<Document>,
    pub full_document_on_update: bool,
    pub full_document_before_change: bool,
    pub initial_backoff_ms: u64,
    pub max_backoff_ms: u64,
    pub max_reconnect_attempts: u32,
    pub batch_size: Option<u32>,
    pub resume_token: Option<Document>,
    pub backoff_jitter: f64,
}

Configuration for change stream behavior.

Use ChangeStreamConfigBuilder to construct instances:

use rigatoni_core::stream::ChangeStreamConfig;

let config = ChangeStreamConfig::builder()
    .full_document_update_lookup()
    .max_reconnect_attempts(10)
    .build();

Fields

pipeline: Vec<Document>

MongoDB aggregation pipeline to filter events

full_document_on_update: bool

Whether to include full document for update operations

full_document_before_change: bool

Whether to include document before change (requires MongoDB 6.0+)

initial_backoff_ms: u64

Initial backoff in milliseconds

max_backoff_ms: u64

Maximum backoff in milliseconds

max_reconnect_attempts: u32

Maximum number of reconnection attempts (0 = infinite)

batch_size: Option<u32>

Batch size for fetching events

resume_token: Option<Document>

Resume token to start from (if any)

backoff_jitter: f64

Backoff jitter factor (0.0 to 1.0) Default: 0.1 (10% jitter)

Implementations

impl ChangeStreamConfig

pub fn builder() -> ChangeStreamConfigBuilder

Creates a new builder for configuring a change stream.

pub fn validate(&self) -> Result<(), StreamError>

Validates the configuration.

Returns an error if:

• initial_backoff_ms is 0
• initial_backoff_ms > max_backoff_ms
• backoff_jitter is not in range [0.0, 1.0]

Trait Implementations

impl Clone for ChangeStreamConfig

fn clone(&self) -> ChangeStreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangeStreamConfig

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

Formats the value using the given formatter.

impl Default for ChangeStreamConfig

fn default() -> Self

Returns the “default value” for a type.