Enum BackpressurePolicy 

pub enum BackpressurePolicy {
    BlockProducer,
    DropOldest,
    DropNewest,
    Error,
}

Policy governing what happens when a stream queue is full.

Configured per-stream or per-flow. The reactor enforces the chosen policy.

Examples

use torvyn_types::BackpressurePolicy;

let policy = BackpressurePolicy::BlockProducer;
assert_eq!(format!("{}", policy), "BlockProducer");

Variants

BlockProducer

Block the producer until space is available (default). This is the safest option and prevents data loss.

DropOldest

Drop the oldest element in the queue to make room for the new one. Useful for real-time systems where freshness matters more than completeness.

DropNewest

Drop the newest element (the one being produced) when the queue is full. The producer continues without blocking; the new element is discarded.

Error

Return an error to the producer when the queue is full. The producer must handle the error (retry, skip, or fail).

Implementations

impl BackpressurePolicy

pub const fn may_lose_data(&self) -> bool

Returns true if this policy can cause data loss.

COLD PATH — called during configuration validation.

Trait Implementations

impl Clone for BackpressurePolicy

fn clone(&self) -> BackpressurePolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackpressurePolicy

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

Formats the value using the given formatter.

impl Default for BackpressurePolicy

fn default() -> BackpressurePolicy

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BackpressurePolicy

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for BackpressurePolicy

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

Formats the value using the given formatter.

impl Hash for BackpressurePolicy

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for BackpressurePolicy

fn eq(&self, other: &BackpressurePolicy) -> 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 BackpressurePolicy

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for BackpressurePolicy

impl Eq for BackpressurePolicy

impl StructuralPartialEq for BackpressurePolicy