Struct RuntimeLeaseCoordinator 

pub struct RuntimeLeaseCoordinator { /* private fields */ }

One-controller, many-observer coordination state for a live runtime.

Implementations

impl RuntimeLeaseCoordinator

pub fn new(lease_ttl_ms: u64) -> RuntimeLeaseCoordinator

Create a coordinator with a non-zero controller lease duration.

pub fn attach( &mut self, client_id: RuntimeClientId, authorization: &RuntimeAuthorization, now_ms: u64, ) -> Result<RuntimeLeaseSnapshot, RuntimeLeaseError>

Register or refresh one authenticated observer.

pub fn heartbeat( &mut self, client_id: &RuntimeClientId, authorization: &RuntimeAuthorization, now_ms: u64, ) -> Result<RuntimeLeaseSnapshot, RuntimeLeaseError>

Refresh observation activity without changing controller ownership.

pub fn authorize( &mut self, authorization: &RuntimeAuthorization, permission: RuntimePermission, now_ms: u64, ) -> Result<RuntimeLeaseSnapshot, RuntimeLeaseError>

Validate a non-controller capability. Observation and lifecycle administration are authorized independently from turn ownership; interactive and approval mutations must use Self::authorize_controller instead.

pub fn claim_control( &mut self, client_id: RuntimeClientId, authorization: &RuntimeAuthorization, now_ms: u64, ) -> Result<RuntimeLeaseSnapshot, RuntimeLeaseError>

Claim the controller when unowned, or renew it when already owned by this client. Another live controller is never displaced implicitly.

pub fn take_control( &mut self, client_id: RuntimeClientId, authorization: &RuntimeAuthorization, now_ms: u64, ) -> Result<RuntimeLeaseSnapshot, RuntimeLeaseError>

Explicitly transfer control to another authorized interactive client.

pub fn authorize_controller( &mut self, client_id: &RuntimeClientId, authorization: &RuntimeAuthorization, permission: RuntimePermission, now_ms: u64, ) -> Result<RuntimeLeaseSnapshot, RuntimeLeaseError>

Validate and renew mutation authority for client_id.

pub fn detach( &mut self, client_id: &RuntimeClientId, now_ms: u64, ) -> RuntimeLeaseSnapshot

Remove an observer and release its controller lease, if held.

pub fn snapshot(&mut self, now_ms: u64) -> RuntimeLeaseSnapshot

Current state after deterministic expiry reconciliation.

Trait Implementations

impl Debug for RuntimeLeaseCoordinator

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

Formats the value using the given formatter.