Struct AgentLifecycleCoordinator 

pub struct AgentLifecycleCoordinator { /* private fields */ }

Coordinates slow session admission with destructive alias mutations.

Implementations

impl AgentLifecycleCoordinator

pub fn reserve_config_mutation( &self, alias: impl Into<String>, ) -> Result<AgentAdmissionReservation, AgentAdmissionError>

Reserve an alias while a config property mutation is prepared and committed. This prevents delete/rename from crossing an autovivifying write without treating an ordinary config edit as destructive work.

pub fn reserve_config_write( &self, ) -> Result<ConfigWriteLease, AgentAdmissionError>

Retain one config write in this daemon generation. Unlike the alias-scoped reservations above, this lease also covers config writes that do not target an agent. Generation drain waits for every retained writer before transferring process ownership to its successor.

pub fn reserve_admission( &self, alias: impl Into<String>, ) -> Result<AgentAdmissionReservation, AgentAdmissionError>

Reserve an alias generation before slow agent construction starts.

pub fn reserve_turn( &self, alias: impl Into<String>, ) -> Result<AgentTurnLease, AgentAdmissionError>

Admit one ordinary message turn without pinning an idle connection.

pub fn alias_generation(&self, alias: &str) -> u64

Return the current generation token for a persistent turn producer.

pub fn reserve_turn_at( &self, alias: impl Into<String>, generation: u64, ) -> Result<AgentTurnLease, AgentAdmissionError>

Admit a turn only when its persistent producer still targets the same alias generation it was constructed for.

pub fn begin_delete( &self, alias: impl Into<String>, ) -> Result<AgentDeleteLease, AgentDeleteBlocker>

Reserve destructive work for one alias after proving no admission or published session is using it. The reservation blocks new admission by marking the alias changing, but does not advance the alias generation: a refused or failed mutation drops the lease and leaves existing producers usable. Only after the config mutation is durably committed does the caller call AgentDeleteLease::commit_destructive_mutation, which advances the generation exactly once and hands destructive ownership to the retained continuation.

pub fn delete_blocker(&self, alias: &str) -> Option<AgentDeleteBlocker>

pub fn live_session_count(&self, alias: &str) -> usize

pub fn active_turn_count(&self, alias: &str) -> usize

pub fn close_generation(&self)

Prevent this generation from admitting new sessions, turns, or destructive work before ingress shutdown begins.

Trait Implementations

impl Clone for AgentLifecycleCoordinator

fn clone(&self) -> AgentLifecycleCoordinator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for AgentLifecycleCoordinator

fn default() -> AgentLifecycleCoordinator

Returns the “default value” for a type.