Struct ActivityRequest 

pub struct ActivityRequest {
    pub activity_type: String,
    pub input: Payload,
    pub task_queue: String,
    pub schedule_to_close_timeout: Option<Duration>,
    pub start_to_close_timeout: Option<Duration>,
}

Activity dispatch request sent through an Aion dispatch channel.

Fields

activity_type: String

Activity type name requested by the workflow.

input: Payload

Type-erased activity input payload.

task_queue: String

Task queue that should receive the activity request.

schedule_to_close_timeout: Option<Duration>

Maximum time from scheduling to completion.

start_to_close_timeout: Option<Duration>

Maximum time from worker start to completion.

Trait Implementations

impl Clone for ActivityRequest

fn clone(&self) -> ActivityRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActivityRequest

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

Formats the value using the given formatter.

impl Eq for ActivityRequest

impl PartialEq for ActivityRequest

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