Struct SessionStagingSourceConfig 

pub struct SessionStagingSourceConfig {
    pub dsn: Option<String>,
    pub dsn_env: Option<String>,
    pub staging_table: String,
    pub staging_schema: String,
    pub mode: SessionStagingMode,
    pub min_age_seconds: u64,
    pub max_sessions: Option<usize>,
}

SP-A staging-table source. Reads the chunkshop-owned append-only staging table (schema.table, default public.chunkshop_staging) and yields one Document per session. mode='realtime' advances the per-session realtime watermark; mode='consolidate' uses a session-level eligibility WHERE so a late event after consolidation triggers a full-staging rebuild (SP-A spec O1 — non-negotiable; see Task 5 of the RM-A plan and Python fix 49861dc).

Fields

dsn: Option<String>

Direct DSN (literal or ${VAR} interpolated at connect time). At least one of dsn / dsn_env must be set.

dsn_env: Option<String>

staging_table: String

staging_schema: String

mode: SessionStagingMode

min_age_seconds: u64

Consolidate-mode: only sessions with max(event_ts|staged_at) < now() - min_age_seconds are selected. Lets quiet sessions consolidate while active sessions stay provisional. Ignored in realtime mode.

max_sessions: Option<usize>

Cap on yielded sessions per run (None = no cap). Mirrors Python.

Trait Implementations

impl Clone for SessionStagingSourceConfig

fn clone(&self) -> SessionStagingSourceConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionStagingSourceConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SessionStagingSourceConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.