Enum WorkerSessionEvent 

pub enum WorkerSessionEvent {
    Task(Box<ProtoActivityTask>),
    Drain,
    ResultAck {
        workflow_id: WorkflowId,
        activity_id: ActivityId,
    },
    Cancel {
        workflow_id: WorkflowId,
        activity_id: ActivityId,
    },
    LivenessPing {
        sequence: u64,
        silence_window: Duration,
    },
}

Event pushed by the worker session receive stream.

Variants

Task(Box<ProtoActivityTask>)

A new activity task to execute.

Drain

Server-initiated drain: the server is going away (restart, deploy, rebalance). The worker finishes in-flight work, reports what it can, stops expecting new tasks, and reconnects after the schedule’s initial backoff. A drain frame latches for the session: the eventual stream end — clean or abrupt — is drain-class and consumes no drop budget.

ResultAck

The server consumed the identified ActivityResult frame; the worker may stop re-reporting it. Clears the matching unacked-tracker entry.

Fields

workflow_id: WorkflowId

Workflow owning the acknowledged result.

activity_id: ActivityId

Activity whose result was acknowledged.

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.

LivenessPing

Transport liveness ping from the server (#197): answer it, promptly, or this worker is not selected for dispatch.

The RUNTIME answers it — never action code. The server is measuring whether it can reach this worker’s DISPATCH path, and an answer produced by a handler would measure whether a handler happens to be running.

Fields

sequence: u64

Sequence to echo back verbatim. An answer carrying anything else is discarded by the server as a stale or fabricated echo.

silence_window: Duration

How long this worker may hear NOTHING on this stream before it should treat the link as dead — the server’s own configured window, carried on every ping so the worker holds no second copy of it.

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for WorkerSessionEvent