Struct AttemptOwnerIndex 

pub struct AttemptOwnerIndex { /* private fields */ }

Server-side attempt -> owning-worker back-index (§6.2).

The router resolves the CURRENT owner of a target attempt here. An entry is installed when an agent attempt is dispatched to a worker and removed when it completes / fails over, so the index reflects who owns each live attempt right now — NOT a stale registry snapshot. A miss is the attempt-scoped no-op.

Implementations

impl AttemptOwnerIndex

pub fn new() -> Self

Build an empty owner index.

pub fn bind(&self, key: AttemptKey, worker: WorkerId)

Record that worker currently owns the session for key.

Called when an agent attempt is dispatched. A later attempt overwrites the prior entry for the same (workflow, activity) at a new attempt number — each attempt is its own key, so a superseded attempt simply has no entry.

pub fn release(&self, key: &AttemptKey)

Remove the owner entry for key (the attempt finished or migrated).

pub fn owner(&self, key: &AttemptKey) -> Option<WorkerId>

The worker currently owning the session for key, if any.

pub fn attempts_for_workflow( &self, workflow_id: &WorkflowId, ) -> Vec<(AttemptKey, WorkerId)>

Every live attempt owned for workflow_id, paired with its owning worker.

The console reads this to enumerate the attempts an operator can currently intervene on within one workflow — only attempts with a LIVE owner appear, so a finished or superseded attempt (which has no entry) is never offered. A poisoned lock yields an empty enumeration, never a panic.

Trait Implementations

impl Clone for AttemptOwnerIndex

fn clone(&self) -> AttemptOwnerIndex

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AttemptOwnerIndex

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

Formats the value using the given formatter.

impl Default for AttemptOwnerIndex

fn default() -> AttemptOwnerIndex

Returns the “default value” for a type.