Enum WorkerDelivery 

pub enum WorkerDelivery {
    Grpc(WorkerTaskSender),
    Liminal(LiminalWorkerDelivery),
}

Transport through which the server delivers a dispatch to a registered worker.

A worker is selected the SAME way regardless of transport (select_worker over the (namespace, task_queue, node) pool key); only the delivery leg differs. The default gRPC path pushes a WorkerMessage onto the worker’s stream mpsc (WorkerDelivery::Grpc); a liminal-connected worker is delivered to by pushing the dispatch out on its existing liminal connection (WorkerDelivery::Liminal, feature-gated). This enum is the minimal transport-agnostic seam: the registry holds it on each WorkerHandle, and the dispatch path reads the variant it needs. The gRPC variant carries exactly the mpsc::Sender it always did, so the gRPC dispatch path is unchanged.

Variants

Grpc(WorkerTaskSender)

gRPC stream delivery: the dispatch path pushes a WorkerMessage onto this mpsc sender, exactly as before this enum existed.

Liminal(LiminalWorkerDelivery)

Liminal server-push delivery: the dispatch path pushes the serialized dispatch out on the worker’s existing liminal connection and awaits the correlated reply. Carries the connection identity needed to address that push.

Trait Implementations

impl Clone for WorkerDelivery

fn clone(&self) -> WorkerDelivery

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerDelivery

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

Formats the value using the given formatter.