Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_number_of_attempts: u32,
    pub first_retry_interval: Duration,
    pub backoff_coefficient: f64,
    pub max_retry_interval: Option<Duration>,
    pub retry_timeout: Option<Duration>,
    pub handle: Option<Arc<dyn Fn(&FailureDetails) -> bool + Send + Sync>>,
}

Policy that governs automatic retry behaviour for activities and sub-orchestrations.

Fields

max_number_of_attempts: u32

Maximum total number of attempts (first execution + retries).

first_retry_interval: Duration

Delay before the first retry.

backoff_coefficient: f64

Multiplier applied to the delay on each successive retry. 1.0 means constant interval; 2.0 means exponential doubling.

max_retry_interval: Option<Duration>

Upper bound on the computed delay between retries.

retry_timeout: Option<Duration>

Maximum total wall-clock time spent retrying (measured from the first failure). Once elapsed, no further retries are scheduled.

handle: Option<Arc<dyn Fn(&FailureDetails) -> bool + Send + Sync>>

Optional predicate called on each failure to decide whether to retry. If None, all failures are retried (up to max_number_of_attempts).

Implementations

impl RetryPolicy

pub fn new(max_number_of_attempts: u32, first_retry_interval: Duration) -> Self

Creates a simple retry policy with the given attempt count and interval.

pub fn with_backoff_coefficient(self, coefficient: f64) -> Self

Set the backoff coefficient (multiplier applied to the delay each retry).

pub fn with_max_retry_interval(self, interval: Duration) -> Self

Set the maximum delay between retries.

pub fn with_retry_timeout(self, timeout: Duration) -> Self

Set the maximum total wall-clock time spent retrying.

pub fn with_handle<F>(self, f: F) -> Self

where F: Fn(&FailureDetails) -> bool + Send + Sync + 'static,

Set a custom predicate to decide whether a failure should be retried.

Example

let policy = RetryPolicy::new(3, Duration::from_secs(1))
    .with_handle(|details| details.error_type != "NonRetryableError");

Trait Implementations

impl Clone for RetryPolicy

fn clone(&self) -> RetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryPolicy

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RetryPolicy

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RetryPolicy

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

where __S: Serializer,

Serialize this value into the given Serde serializer.