Struct RunRetryPolicy

pub struct RunRetryPolicy { /* private fields */ }

This struct represents the policy to execute retries for run closures.

Implementations

impl RunRetryPolicy

pub fn new() -> Self

Create a new retry policy.

pub fn initial_delay(self, initial_interval: Duration) -> Self

Initial retry delay for the first retry attempt.

pub fn exponentiation_factor(self, factor: f32) -> Self

Exponentiation factor to use when computing the next retry delay.

pub fn max_delay(self, max_interval: Duration) -> Self

Maximum delay between retries.

pub fn max_attempts(self, max_attempts: u32) -> Self

Gives up retrying when either at least the given number of attempts is reached, or max_duration (if set) is reached first.

Note: The number of actual retries may be higher than the provided value. This is due to the nature of the run operation, which executes the closure on the service and sends the result afterward to Restate.

Infinite retries if this field and max_duration are unset.

pub fn max_duration(self, max_duration: Duration) -> Self

Gives up retrying when either the retry loop lasted at least for this given max duration, or max_attempts (if set) is reached first.

Note: The real retry loop duration may be higher than the given duration. This is due to the nature of the run operation, which executes the closure on the service and sends the result afterward to Restate.

Infinite retries if this field and max_attempts are unset.

Trait Implementations

impl Clone for RunRetryPolicy

fn clone(&self) -> RunRetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunRetryPolicy

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

Formats the value using the given formatter.

impl Default for RunRetryPolicy

fn default() -> Self

Returns the “default value” for a type.