Struct BackPressure 

pub struct BackPressure { /* private fields */ }

The backpressure mechanism for unbounded inboxes.

Default

exponential backoff starting 5 messages in the inbox at 25 ns, with a growth-factor of 1.3

Implementations

impl BackPressure

pub fn linear(starts_at: usize, timeout: Duration) -> Self

Creates a new linear backpressure.

The timeout is calculated as follows: timeout = timeout * (msg_count - start_at)

Panics

Panics if the timeout is bigger than 213_503 days.

pub fn exponential(starts_at: usize, timeout: Duration, factor: f32) -> Self

Creates a new linear backpressure.

The timeout is calculated as follows: timeout = timeout * (factor ^ (msg_count - start_at))

Panics

Panics if the factor is negative, or if the timeout is bigger than 213_503 days.

pub fn disabled() -> Self

Create a new backpressure that is disabled.

Trait Implementations

impl Clone for BackPressure

fn clone(&self) -> BackPressure

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackPressure

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

Formats the value using the given formatter.

impl Default for BackPressure

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for BackPressure

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