Struct WorkerRegistry 

pub struct WorkerRegistry { /* private fields */ }

Implementations

impl WorkerRegistry

pub fn new(policy: DelegationPolicy) -> Self

pub fn foreground_model(&self) -> &QualifiedModelId

pub fn policy(&self) -> &DelegationPolicy

pub fn grant_worker_model( &mut self, model: QualifiedModelId, ) -> Result<(), &'static str>

Applies an explicit mid-session user trust grant for one exact worker model. Existing worker lifecycle state and limits are unchanged; the grant is visible to the next dispatch decision.

pub fn total_dispatched(&self) -> usize

pub fn telemetry(&self) -> &VecDeque<OrchestrationEvent>

pub fn dropped_telemetry(&self) -> u64

pub fn mode(&self) -> EnforcementMode

pub fn rollback_dispatch( &mut self, h: &WorkerHandle, ) -> Result<(), &'static str>

pub fn validate_dispatch( &self, model: &QualifiedModelId, ) -> Result<(), DispatchDenied>

pub fn validate_dispatch_at( &self, model: &QualifiedModelId, now_unix: u64, ) -> Result<(), DispatchDenied>

pub fn authorize_dispatch( &mut self, model: &QualifiedModelId, role: WorkerRole, writes: WorkerWritePolicy, ) -> Result<WorkerHandle, DispatchDenied>

pub fn authorize_dispatch_at( &mut self, model: &QualifiedModelId, role: WorkerRole, writes: WorkerWritePolicy, now_unix: u64, ) -> Result<WorkerHandle, DispatchDenied>

pub fn mark_starting(&mut self, h: &WorkerHandle) -> Result<(), &'static str>

pub fn mark_running(&mut self, h: &WorkerHandle) -> Result<(), &'static str>

pub fn poll( &mut self, h: &WorkerHandle, fingerprint: &str, ) -> Result<(), &'static str>

pub fn is_stalled(&self, h: &WorkerHandle) -> Result<bool, &'static str>

pub fn steer(&mut self, h: &WorkerHandle) -> Result<(), &'static str>

pub fn mark_terminal( &mut self, h: &WorkerHandle, _: WorkerTerminal, ) -> Result<(), &'static str>

pub fn collect(&mut self, h: &WorkerHandle) -> Result<(), &'static str>

pub fn reconcile(&mut self, h: &WorkerHandle) -> Result<(), &'static str>

pub fn retire_reconciled(&mut self, h: &WorkerHandle) -> bool

Drop metadata only after result reconciliation AND runtime-handle retirement. Lifetime dispatch count and monotonic identity sequence are never refunded.

pub fn completion_gate(&self) -> CompletionGate

pub fn all_unreconciled_ids(&self) -> Vec<String>

All non-reconciled worker IDs — including running ones. Used by the reaper to decide retention (don’t GC a worker the orchestration still tracks, even if the completion gate lets the turn through).

pub fn check_foreground_write(&self, path: &str) -> ScopeDecision