Struct RestartSettings 

pub struct RestartSettings { /* private fields */ }

Backoff settings for RestartSource, RestartFlow, and RestartSink.

The restart counter follows Akka’s maxRestartsWithin rule: once the reset window elapses, both the restart count and exponential backoff position are reset. The random factor adds up to random_factor * computed_backoff extra delay.

Implementations

impl RestartSettings

pub fn new( min_backoff: Duration, max_backoff: Duration, random_factor: f64, ) -> Self

pub fn min_backoff(&self) -> Duration

pub fn max_backoff(&self) -> Duration

pub fn random_factor(&self) -> f64

pub fn max_restarts(&self) -> usize

pub fn max_restarts_within(&self) -> Duration

pub fn with_min_backoff(self, value: Duration) -> Self

pub fn with_max_backoff(self, value: Duration) -> Self

pub fn with_random_factor(self, value: f64) -> Self

pub fn with_max_restarts(self, count: usize, within: Duration) -> Self

Trait Implementations

impl Clone for RestartSettings

fn clone(&self) -> RestartSettings

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RestartSettings

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

Formats the value using the given formatter.