Enum WorkerSessionEvent 

pub enum WorkerSessionEvent {
    Task(ProtoActivityTask),
    Drain,
    Cancel {
        workflow_id: WorkflowId,
        activity_id: ActivityId,
    },
}

Event pushed by the worker session receive stream.

Variants

Task(ProtoActivityTask)

A new activity task to execute.

Drain

Server is draining and will not dispatch more activity tasks on this stream.

Cancel

Cooperative cancellation for an in-flight activity.

The current AW worker proto in this worktree does not yet carry this frame, but fake sessions can emit it and the runtime handles it without forcing task termination. When AW lands the wire variant, decode_server_message should map it to this event.

Fields

workflow_id: WorkflowId

Workflow owning the activity.

activity_id: ActivityId

Activity to mark cancelled.

Trait Implementations

impl Clone for WorkerSessionEvent

fn clone(&self) -> WorkerSessionEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerSessionEvent

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

Formats the value using the given formatter.

impl Eq for WorkerSessionEvent

impl PartialEq for WorkerSessionEvent

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