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.

Carried on the wire as CancelActivity and decoded by decode_cancel_activity. The runtime handles it without forcing task termination: the activity’s cancellation token is tripped and the handler is given the chance to stop on its own terms.

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