Enum StreamingBackpressure 

pub enum StreamingBackpressure {
    Block,
    DropOldest,
    Reject,
}

Backpressure strategy when buffer is full.

Stored in source/sink configs and exposed in SQL DDL (BACKPRESSURE = '...'). The streaming channel always blocks on full; this enum is used by higher-level layers (e.g., catalog snapshot ring) to decide overflow behavior.

Variants

Block

Block until space is available (default).

DropOldest

Drop the oldest item to make room.

Reject

Reject the push immediately.

Trait Implementations

impl Clone for BackpressureStrategy

fn clone(&self) -> BackpressureStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackpressureStrategy

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

Formats the value using the given formatter.

impl Default for BackpressureStrategy

fn default() -> BackpressureStrategy

Returns the “default value” for a type.

impl FromStr for BackpressureStrategy

type Err = String

The associated error which can be returned from parsing.

fn from_str( s: &str, ) -> Result<BackpressureStrategy, <BackpressureStrategy as FromStr>::Err>

Parses a string s to return a value of this type.

impl PartialEq for BackpressureStrategy

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for BackpressureStrategy

impl Eq for BackpressureStrategy

impl StructuralPartialEq for BackpressureStrategy