Struct WatchConfig 

pub struct WatchConfig {
    pub in_process: bool,
    pub buffer_size: usize,
    pub poll_interval_ms: u64,
}

Configuration for the watch system (in-process and cross-process).

Controls whether in-process channel subscriptions are enabled, the channel buffer size for real-time experience notifications, and the poll interval for cross-process change detection.

Example

use pulsedb::Config;

let config = Config {
    watch: pulsedb::WatchConfig {
        in_process: true,
        buffer_size: 500,
        poll_interval_ms: 200,
    },
    ..Default::default()
};

Fields

in_process: bool

Enable in-process watch subscriptions via crossbeam channels.

When true (default), watch_experiences() streams receive real-time events. When false, in-process event dispatch is skipped entirely — only cross-process poll_changes() remains available.

Default: true

buffer_size: usize

Maximum number of events buffered per subscriber (in-process).

When a subscriber’s channel is full, new events are dropped for that subscriber (with a warning log). The publisher never blocks.

Default: 1000

poll_interval_ms: u64

Poll interval in milliseconds for cross-process change detection.

Reader processes call poll_changes() at this interval to check for new experiences written by the writer process.

Default: 100

Trait Implementations

impl Clone for WatchConfig

fn clone(&self) -> WatchConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WatchConfig

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

Formats the value using the given formatter.

impl Default for WatchConfig

fn default() -> Self

Returns the “default value” for a type.