Enum Router 

pub enum Router {
    To(AgentId),
    ToPrincipal {
        agent: AgentId,
        principal: PrincipalId,
    },
    Broadcast,
    ToCapable(CapabilitySelector),
    AllCapable(CapabilitySelector),
}

Where a message is addressed: one specific agent, every listener on the topic, or resolved by capability against the card registry (one capable agent, or all of them for fan-out).

Variants

To(AgentId)

ToPrincipal

Route to one named agent only when its live connection authenticated as the required principal.

Fields

agent: AgentId

principal: PrincipalId

Broadcast

ToCapable(CapabilitySelector)

Route to the one capable agent the policy picks.

AllCapable(CapabilitySelector)

Route to every capable agent (fan-out: a diagnostic pool, a verifier panel).

Implementations

impl Router

pub fn to(agent: AgentId) -> Self

Route to one agent (stamps agdx.to).

pub fn to_principal(agent: AgentId, principal: PrincipalId) -> Self

Route to agent only when its live presence is bound to principal.

pub fn broadcast() -> Self

Clear any target so every consumer-group member may handle the message.

pub fn to_capable(skill: impl Into<String>, policy: RoutePolicy) -> Self

Route to the one agent advertising skill that policy picks.

pub fn all_capable(skill: impl Into<String>, policy: RoutePolicy) -> Self

Route to every agent advertising skill (fan-out).

pub fn apply(&self, provenance: &mut Provenance)

Stamp (or clear) the target for the direct variants. The capability variants are resolved against the registry by resolve_targets, not stamped directly, so here they leave the target unset (a safe broadcast) rather than mis-target.

pub fn resolve_targets( &self, registry: &AgentRegistry<'_>, now_micros: u64, ) -> Result<Vec<AgentId>, LaserError>

Resolve to the concrete target agent(s) against registry at now_micros: To is the one agent, Broadcast is the empty list (no target), ToCapable is the one the policy picks, and AllCapable is every capable agent. Errors with LaserError::NoCapableAgent when a capability variant matches no live agent.

Trait Implementations

impl Clone for Router

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Router

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

Formats the value using the given formatter.