Enum BackpressureStrategy 

pub enum BackpressureStrategy {
    DropOldest,
    DropNewest,
    Block,
    Adaptive,
    ExponentialBackoff {
        initial_delay_ms: u64,
        max_delay_ms: u64,
    },
}

Backpressure handling strategies

Variants

DropOldest

Drop oldest updates when buffer is full

DropNewest

Drop newest updates when buffer is full

Block

Block until buffer has space

Adaptive

Adaptive strategy based on system load

ExponentialBackoff

Exponential backoff

Fields

initial_delay_ms: u64

max_delay_ms: u64

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BackpressureStrategy

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

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 Serialize for BackpressureStrategy

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for BackpressureStrategy