Struct TaskRetryPolicy 

#[non_exhaustive]
pub struct TaskRetryPolicy {
    pub minimum_backoff: Option<Duration>,
    pub maximum_backoff: Option<Duration>,
    /* private fields */
}

Task Retry Policy is implemented on a best-effort basis. Retry delay will be exponential based on provided minimum and maximum backoffs. https://en.wikipedia.org/wiki/Exponential_backoff. Note that the delay between consecutive task restarts may not always precisely match the configured settings. This can happen when the ConnectCluster is in rebalancing state or if the ConnectCluster is unresponsive etc. The default values for minimum and maximum backoffs are 60 seconds and 30 minutes respectively.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

minimum_backoff: Option<Duration>

Optional. The minimum amount of time to wait before retrying a failed task. This sets a lower bound for the backoff delay.

maximum_backoff: Option<Duration>

Optional. The maximum amount of time to wait before retrying a failed task. This sets an upper bound for the backoff delay.

Implementations

impl TaskRetryPolicy

pub fn new() -> Self

pub fn set_minimum_backoff<T>(self, v: T) -> Self

where T: Into<Duration>,

Sets the value of minimum_backoff.

pub fn set_or_clear_minimum_backoff<T>(self, v: Option<T>) -> Self

where T: Into<Duration>,

Sets or clears the value of minimum_backoff.

pub fn set_maximum_backoff<T>(self, v: T) -> Self

where T: Into<Duration>,

Sets the value of maximum_backoff.

pub fn set_or_clear_maximum_backoff<T>(self, v: Option<T>) -> Self

where T: Into<Duration>,

Sets or clears the value of maximum_backoff.

Trait Implementations

impl Clone for TaskRetryPolicy

fn clone(&self) -> TaskRetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskRetryPolicy

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

Formats the value using the given formatter.

impl Default for TaskRetryPolicy

fn default() -> TaskRetryPolicy

Returns the “default value” for a type.

impl Message for TaskRetryPolicy

fn typename() -> &'static str

The typename of this message.

impl PartialEq for TaskRetryPolicy

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