Struct ActivityRetryPolicy

pub struct ActivityRetryPolicy {
    pub max_attempts: Option<u32>,
    pub backoff: Option<ActivityBackoff>,
    pub non_retryable_error_types: Vec<String>,
}

Durable server-side retry policy for one activity execution.

Fields

max_attempts: Option<u32>

backoff: Option<ActivityBackoff>

non_retryable_error_types: Vec<String>

Implementations

impl ActivityRetryPolicy

pub fn new(max_attempts: u32) -> Self

Start a policy with a finite attempt budget, including the first attempt.

pub fn backoff_intervals( self, intervals: impl IntoIterator<Item = Duration>, ) -> Self

pub fn exponential_backoff( self, initial_interval: Duration, coefficient: u32, maximum_interval: Option<Duration>, ) -> Self

pub fn non_retryable_error_type(self, error_type: impl Into<String>) -> Self

pub fn non_retryable_error_types( self, error_types: impl IntoIterator<Item = impl Into<String>>, ) -> Self

Trait Implementations

impl Clone for ActivityRetryPolicy

fn clone(&self) -> ActivityRetryPolicy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ActivityRetryPolicy

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

Formats the value using the given formatter.

impl Default for ActivityRetryPolicy

fn default() -> ActivityRetryPolicy

Returns the “default value” for a type.

impl PartialEq for ActivityRetryPolicy

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

impl StructuralPartialEq for ActivityRetryPolicy