Struct tiny_actor::config::BackPressure

pub struct BackPressure {
    pub start_at: usize,
    pub timeout: Duration,
    pub growth: Growth,
}

This decides how an actor with an unbouned channel handles message overload. This works by applying a timeout whenever there are more than start_at messages in the channel. The timeout Growth is multiplied with the given timeout.

Default

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

Fields

start_at: usize

timeout: Duration

growth: Growth

Implementations

impl BackPressure

pub fn disabled() -> Self

Get a back-pressure configuration that is disabled. This will never return a timeout, no matter how full the channel is.

Trait Implementations

impl Clone for BackPressure

fn clone(&self) -> BackPressure

Returns a copy 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<BackPressure> for BackPressure

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl StructuralPartialEq for BackPressure