Enum RouteDecision 

pub enum RouteDecision {
    Local,
    Forward {
        owner: NodeRef,
        shard: usize,
    },
    NotOwner {
        shard: usize,
    },
}

The routing verdict for a mutation/read (signal/query/cancel) whose target workflow_id is known up front.

Variants

Local

This node owns the workflow’s shard, owns all shards, is not clustered, or the owner is Unknown (route optimistically; the fence backstops): proceed to the local engine.

Forward

A live remote node owns the workflow’s shard. R-2 cannot forward yet, so the edge returns NotOwner for this; R-3 forwards to owner when it has a grpc_addr and returns NotOwner only when it does not.

Fields

owner: NodeRef

The resolved remote owner (may or may not carry a grpc_addr).

shard: usize

The shard the workflow’s durable state lives on (for the NotOwner fallback message and re-resolution).

NotOwner

Another node owns the workflow’s shard and there is no forwarding target (no directory, or the owner declared no gRPC address). Return the typed retryable NotOwner carrying the shard so a routing-aware caller can re-resolve and retry.

Fields

shard: usize

The distribution shard the workflow’s durable state lives on.

Trait Implementations

impl Clone for RouteDecision

fn clone(&self) -> RouteDecision

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RouteDecision

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

Formats the value using the given formatter.

impl Eq for RouteDecision

impl PartialEq for RouteDecision

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for RouteDecision