Struct BackpressureConfig 

pub struct BackpressureConfig {
    pub spill_buffer_frames: usize,
    pub policy: BackpressurePolicy,
    pub backoff: BackoffConfig,
}

Bounded spill buffer + overflow policy + retry backoff for the frame drain loop. See .yah/docs/working/W248-wal-streamer-hardening.md (“Explicit backpressure”).

Fields

spill_buffer_frames: usize

Max frames buffered in memory — read from the WAL but not yet confirmed uploaded — before the overflow policy applies. Once full, the drain loop must resolve the buffered frames before reading further.

R761-F2: those frames go up as ONE batch object, so this also caps the largest object the sink writes at spill_buffer_frames * (24 + page_size) — ~1 MB at this default and a 4 KB page. Raising it trades memory and per-object retry cost for fewer Class A ops on a heavy-writing tenant; lowering it to 1 restores one PUT per frame (under the batch key shape, not the pre-R761-F2 one).

policy: BackpressurePolicy

backoff: BackoffConfig

Trait Implementations

impl Clone for BackpressureConfig

fn clone(&self) -> BackpressureConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for BackpressureConfig

impl Debug for BackpressureConfig

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

Formats the value using the given formatter.

impl Default for BackpressureConfig

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for BackpressureConfig

fn eq(&self, other: &BackpressureConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for BackpressureConfig