Enum WorkerMessage 

pub enum WorkerMessage {
    ActivityTask(Box<ProtoActivityTask>),
    DrainRequest,
    LivenessPing(ProtoLivenessPing),
    CancelActivity(ProtoCancelActivity),
}

Message queued from server-side dispatch/shutdown into a worker stream writer.

Variants

ActivityTask(Box<ProtoActivityTask>)

Activity invocation pushed to a worker.

DrainRequest

Graceful-shutdown notification; no new work will be dispatched.

LivenessPing(ProtoLivenessPing)

Transport liveness ping pushed by the liveness probe (#197).

It travels this channel — the SAME one dispatches travel — deliberately. The fact the probe needs is whether the server can reach this worker’s DISPATCH path, and a ping on a parallel channel could be answered by a process whose dispatch path is dead. Answered by the worker SDK RUNTIME, never by action code.

CancelActivity(ProtoCancelActivity)

Ask the worker to stop ONE in-flight activity (#233).

A request, not a guarantee: pushing this proves only that the server asked. Whether the work stops depends on the worker still holding the activity and on the action being interruptible, and neither is observable from here.

It travels this channel — the SAME one the dispatch travelled — so the cancel cannot overtake or bypass the task it interrupts, and so a worker whose dispatch path is dead cannot appear to have been told.

Trait Implementations

impl Clone for WorkerMessage

fn clone(&self) -> WorkerMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerMessage

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

Formats the value using the given formatter.

impl Eq for WorkerMessage

impl PartialEq for WorkerMessage

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for WorkerMessage