Struct OpenActivity 

pub struct OpenActivity {
    pub activity_id: ActivityId,
    pub activity_type: String,
    pub task_queue: String,
    pub node: Option<String>,
    pub attempt: u32,
    pub dispatched_at: DateTime<Utc>,
}

One activity the active run segment records as dispatched and unterminated.

The address fields are the ones the engine STAMPED on the dispatch (ActivityScheduled carries the resolved task_queue and node), so this is the address the dispatch really went to, not a re-resolution that could disagree with it.

Fields

activity_id: ActivityId

Activity ordinal recorded in history.

activity_type: String

Activity type the dispatch needs served.

task_queue: String

Task queue stamped on the recorded ActivityScheduled.

node: Option<String>

Node affinity stamped on the recorded ActivityScheduled, if any.

attempt: u32

One-based delivery attempt stamped on the recorded ActivityStarted.

dispatched_at: DateTime<Utc>

recorded_at of the ActivityStarted — when the ENGINE dispatched.

Trait Implementations

impl Clone for OpenActivity

fn clone(&self) -> OpenActivity

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OpenActivity

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

Formats the value using the given formatter.

impl Eq for OpenActivity

impl PartialEq for OpenActivity

fn eq(&self, other: &OpenActivity) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for OpenActivity