Struct StreamPolicy 

pub struct StreamPolicy {

    pub max_admission_rows: u32,
    pub max_admission_bytes: u64,
    pub max_fetched_rows: u32,
    pub max_fetched_bytes: u64,
    pub group_pending: PendingBudget,
    pub welcome_pending: PendingBudget,
    pub identity_pending: PendingBudget,
    pub max_pending_rows_per_topic: u64,
    pub max_pending_bytes_per_topic: u64,
    pub max_dependency_requests: usize,
    pub max_local_read_rows: u32,
    pub max_local_read_bytes: u64,
    pub receiver_fallback_interval: Duration,
    pub active_database_poll_interval: Duration,
    pub default_consumer_lease_duration: Duration,
    pub identity_reference_wait: Duration,
    pub barrier_timeout: Duration,
    pub blocked_welcome_rescan_interval: Duration,
    pub permanent_retry_initial: Duration,
    pub permanent_retry_max: Duration,
}

Bounds apply to encoded items and row metadata, not to the whole database.

Fields

max_admission_rows: u32

Maximum rows committed in one durable admission transaction.

max_admission_bytes: u64

Maximum encoded bytes committed in one admission transaction.

max_fetched_rows: u32

Maximum rows accepted from one network fetch, before admission chunks.

max_fetched_bytes: u64

Maximum bytes accepted from one network fetch; independent of per-kind budgets.

group_pending: PendingBudget

Total retained group-envelope budget across all group topics.

welcome_pending: PendingBudget

Total retained Welcome budget, separate from group and identity budgets.

identity_pending: PendingBudget

Total retained identity-envelope budget across identity topics.

max_pending_rows_per_topic: u64

Per-topic row limit, applied alongside the total kind budget.

max_pending_bytes_per_topic: u64

Per-topic byte limit; rejected chunks do not advance F.

max_dependency_requests: usize

Maximum concurrent dependency and fixed-target requests.

max_local_read_rows: u32

Maximum stored candidates loaded by one local-delivery read.

max_local_read_bytes: u64

Maximum candidate bytes checked before loading message blobs.

receiver_fallback_interval: Duration

Bound on stream-first receipt waits. Explicit sync queries without this wait.

active_database_poll_interval: Duration

Poll interval for cross-process progress and missed local wake events.

default_consumer_lease_duration: Duration

Default-reader ownership expires after this interval without renewal.

identity_reference_wait: Duration

Healthy-primary wait before an absent exact identity reference is rejected.

barrier_timeout: Duration

One budget for target capture, receipt, processing, and required send follow-up work.

blocked_welcome_rescan_interval: Duration

Interval between full rescans of blocked Welcome rows.

permanent_retry_initial: Duration

First delay before retrying a source that failed with a permanent error.

permanent_retry_max: Duration

Longest delay between retries of a repeatedly failing source.

Implementations

impl StreamPolicy

pub fn fetched_limits(&self) -> IncomingBatchLimits

The bounds of one fetched page.

pub fn incoming_limits(&self, kind: NetworkEntityKind) -> IncomingLimits

The incoming limits for one entity kind.

Trait Implementations

impl Clone for StreamPolicy

fn clone(&self) -> StreamPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamPolicy

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

Formats the value using the given formatter.

impl Default for StreamPolicy

fn default() -> StreamPolicy

Returns the “default value” for a type.