Struct RuntimeOwner 

pub struct RuntimeOwner { /* private fields */ }

Unique owner of the executor, supervisor, ledger, connectors, and shutdown state.

Implementations

impl RuntimeOwner

pub fn state(&self) -> RuntimeState

Current lifecycle state.

pub fn ledger_len(&self) -> usize

Active ledger entry count.

pub fn owned_task_count(&self) -> u32

Supervisor-owned task count (§22.3 stopped proof).

pub fn live_connector_owners(&self) -> u32

Live ConnectorOwner tasks (register-before-I/O; Hang-ready observation).

pub fn tool_spill_pending(&self) -> usize

Runtime-scoped tool spill pending count (joins + orphans; §22.4 / Stopped gate).

pub fn global_reservations(&self) -> usize

Global reservation count.

pub fn channel_reservations(&self, channel: &ChannelId) -> usize

Channel reservation count (D-040 rollback observability).

pub fn channel_count(&self) -> usize

Number of realized channels owned by this runtime.

pub fn mcp_local_addr(&self) -> Option<SocketAddr>

Bound MCP loopback address when enable_mcp_listener and the gateway is live.

pub fn mcp_gateway(&self) -> Option<McpGatewayHandle>

Cloneable MCP gateway handle while the RuntimeService is live.

pub fn begin_shutdown(&self) -> ShutdownTicket

Begin shutdown (idempotent). Synchronously moves admission to Quiescing.

Control delivery is best-effort on the control queue; the supervisor also observes Quiescing via an internal wake so a full control queue cannot strand the runtime.

pub async fn wait_stopped(&mut self, deadline: Duration) -> ShutdownWaitOutcome

Wait until Stopped or the deadline elapses (v2: timeout ⇒ Quiescing, not false Stopped).

D-049: the deadline bounds the entire API — including the executor OS thread join. Public Stopped is published only after that join.

Trait Implementations

impl Drop for RuntimeOwner

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.