Struct ControlRegistry 

pub struct ControlRegistry { /* private fields */ }

The worker’s attempt back-index: maps a live SessionKey to its session control leg, so a routed command reaches the exact in-flight attempt.

A session installs itself with Self::register when it starts and the returned SessionGuard removes it on drop, so the index tracks exactly the sessions running on this worker. It is cheap to clone (an Arc inside), so the liminal serve loop and the session-spawn path share one index.

Implementations

impl ControlRegistry

pub fn new() -> Self

Build an empty control registry.

pub fn register( &self, key: SessionKey, control: UnboundedSender<ControlMessage>, capabilities: InterventionCapabilities, ) -> SessionGuard

Register a live session’s control leg under its key, returning a guard whose drop deregisters it (so the index never routes to a gone session).

The control sender is the driver’s control channel (the receiver half is handed to spawn_agent as its control_receiver); capabilities is the session’s advertised neutral primitive set, which the worker gates on before delivering a command.

pub async fn deliver(&self, command: InterventionCommand) -> InterventionOutcome

Deliver one routed command to the session that owns its target, returning the neutral InterventionOutcome ack.

Resolves the target session by (workflow, activity, attempt). When no live session owns the target, returns InterventionOutcome::stale_target — the attempt-scoped no-op. When the session’s advertised capabilities do not include the command’s primitive, returns InterventionOutcome::capability_not_supported WITHOUT delivering it (the worker gate mirrors the server gate; a well-behaved server never sends an unadvertised primitive, but the worker refuses one cleanly if it arrives). Otherwise it delivers the command and awaits the driver’s ack.

Trait Implementations

impl Clone for ControlRegistry

fn clone(&self) -> ControlRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ControlRegistry

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

Formats the value using the given formatter.

impl Default for ControlRegistry

fn default() -> ControlRegistry

Returns the “default value” for a type.