Struct StreamConfig 

pub struct StreamConfig {
    pub snapshot_ttl_ms: u64,
    pub chunk_default_pages: usize,
    pub chunk_min_pages: usize,
    pub chunk_max_pages: usize,
    pub chunk_max_rows: usize,
    pub chunk_max_latency_ms: u64,
    pub max_global_streams: usize,
    pub max_per_principal_streams: usize,
    pub default_verify: VerifyMode,
}

Frozen snapshot of the stream.* namespace at lease open. Acceptance criterion: a red_config mutation while a stream is running does not retroactively change the running stream’s behaviour — that is, the per-lease config is value-typed and not a back-reference.

Fields

snapshot_ttl_ms: u64

chunk_default_pages: usize

chunk_min_pages: usize

chunk_max_pages: usize

chunk_max_rows: usize

chunk_max_latency_ms: u64

max_global_streams: usize

Process-wide concurrent stream cap (issue #761 / S2). Acquiring the (N+1)th slot is refused with server_stream_capacity_exhausted.

max_per_principal_streams: usize

Per-principal concurrent stream cap (issue #761 / S2). Acquiring the (M+1)th slot for a single principal is refused with principal_stream_quota_exhausted even when the global counter still has room.

default_verify: VerifyMode

Issue #765 / S6 — default end-to-end verification mode for input streams when the open frame does not request one (stream.integrity.default_verify, "none" per ADR 0029).

Implementations

impl StreamConfig

pub const DEFAULT: StreamConfig

Defaults match ADR 0029. snapshot_ttl_ms is the only key observable mid-stream; the chunk caps only affect framing.

pub fn load(runtime: &RedDBRuntime) -> StreamConfig

Read every stream.* key from red_config over the runtime’s KV store. Missing keys fall back to Self::DEFAULT. Unparseable or out-of-range values fall back silently — bad config never gets to terminate a request that would otherwise succeed.

pub fn production_buffer_bytes(&self) -> usize

Page-aligned production buffer size in bytes. Acceptance criterion: “production buffer is always N × 16 KiB”.

Trait Implementations

impl Clone for StreamConfig

fn clone(&self) -> StreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamConfig

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

Formats the value using the given formatter.

impl Default for StreamConfig

fn default() -> StreamConfig

Returns the “default value” for a type.

impl Copy for StreamConfig