Struct LocalActivityOptions

pub struct LocalActivityOptions {
    pub retry_policy: Option<ActivityRetryPolicy>,
    pub start_to_close_timeout: Option<Duration>,
    pub schedule_to_close_timeout: Option<Duration>,
    pub heartbeat_timeout: Option<Duration>,
}

Retry and timeout settings for an activity executed by the workflow worker.

Local activities bypass the activity queue. They do not accept routing, schedule-to-start timeouts, or remote activity cancellation policies.

Fields

retry_policy: Option<ActivityRetryPolicy>

start_to_close_timeout: Option<Duration>

schedule_to_close_timeout: Option<Duration>

heartbeat_timeout: Option<Duration>

Implementations

impl LocalActivityOptions

pub fn new() -> Self

pub fn retry_policy(self, policy: ActivityRetryPolicy) -> Self

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

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

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

Trait Implementations

impl Clone for LocalActivityOptions

fn clone(&self) -> LocalActivityOptions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for LocalActivityOptions

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

Formats the value using the given formatter.

impl Default for LocalActivityOptions

fn default() -> LocalActivityOptions

Returns the “default value” for a type.

impl PartialEq for LocalActivityOptions

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

impl StructuralPartialEq for LocalActivityOptions