Struct ClusterRuntimeHandle 

pub struct ClusterRuntimeHandle { /* private fields */ }

Shared handle to a live NodeRuntime stored on AppState.

The runtime lives behind a mutex so admin handlers can call async mut methods (split_tablet / merge_tablets). shutdown takes the runtime out once so graceful stop is single-shot even when the handle is cloned across the router and ServerControl.

Implementations

impl ClusterRuntimeHandle

pub async fn start( options: ClusterRuntimeOptions, ) -> Result<Self, ClusterRuntimeError>

Load identity + bootstrap state from options.node_data, start the runtime, and wrap it. Fails closed when the node has not been provisioned (cluster init / cluster join).

pub fn node_data(&self) -> &Path

Node data directory this runtime was started from.

pub async fn is_live(&self) -> bool

Whether the runtime is still live (not yet shut down).

pub async fn runtime_status_json(&self) -> Result<Value, ClusterRuntimeError>

JSON view of RuntimeStatus for admin status surfaces.

pub async fn transfer_leader( &self, tablet_id: TabletId, to: NodeId, ) -> Result<Value, ClusterRuntimeError>

TRANSFER LEADER <tablet> TO <node> against a live tablet group.

pub async fn split_tablet( &self, tablet_id: TabletId, at_key_hex: Option<String>, ) -> Result<Value, ClusterRuntimeError>

SPLIT TABLET against a live runtime (requires meta + hosted tablet).

pub async fn merge_tablets( &self, left: TabletId, right: TabletId, ) -> Result<Value, ClusterRuntimeError>

MERGE TABLETS against a live runtime (requires meta + hosted pair).

pub fn runtime_mutex(&self) -> Arc<Mutex<Option<NodeRuntime>>>

Direct access for tests that need to seed tablets onto the live runtime.

pub async fn attach_internal_rpc_handler( &self, service_id: u32, handler: Arc<dyn InternalRpcHandler>, ) -> Result<(), ClusterRuntimeError>

Installs one authenticated node-internal RPC service.

pub async fn internal_rpc_client( &self, ) -> Result<NodeInternalRpcClient, ClusterRuntimeError>

Gets a cloneable client for authenticated internal fan-out.

pub fn tablet_database_try(&self, tablet_id: TabletId) -> Option<Arc<Database>>

Resolve the applied engine core for one locally hosted tablet.

Uses try_lock so fragment/AI workers never block the async runtime mutex; contention fails closed with None (caller retries / errors).

pub async fn tablet_ids(&self) -> Result<Vec<TabletId>, ClusterRuntimeError>

Hosted tablet ids on this node (tablet-id order), for public data routing.

pub async fn tablet_rows( &self, tablet_id: TabletId, ) -> Result<BTreeMap<Key, Vec<u8>>, ClusterRuntimeError>

Current applied opaque tablet rows (local replica view) for a hosted tablet.

pub async fn tablet_typed_rows( &self, tablet_id: TabletId, ) -> Result<TypedTabletRows, ClusterRuntimeError>

Typed user-table rows of a bound hosted tablet.

pub async fn bind_tablet_user_table( &self, tablet_id: TabletId, binding: TabletTableBinding, ) -> Result<TabletTableBinding, ClusterRuntimeError>

Bind a hosted tablet to a typed user-table schema (P0.3).

pub async fn tablet_table_binding( &self, tablet_id: TabletId, ) -> Result<Option<TabletTableBinding>, ClusterRuntimeError>

Current typed binding for a hosted tablet, if any.

pub async fn write_tablet_rows( &self, tablet_id: TabletId, entries: &[(Key, Vec<u8>)], ) -> Result<GroupCommitReceipt, ClusterRuntimeError>

Raft-propose upserts into a hosted tablet’s opaque MVCC keyspace.

The local replica must be the group leader; [ConsensusError::NotLeader] surfaces through ClusterRuntimeError::Runtime with a leader hint.

pub async fn write_tablet_ops( &self, tablet_id: TabletId, operations: Vec<TabletWriteOperation>, ) -> Result<GroupCommitReceipt, ClusterRuntimeError>

Raft-propose typed user-table mutations (COMMAND_TYPE_TABLET_WRITE).

pub async fn shutdown(&self) -> Result<(), ClusterRuntimeError>

Graceful shutdown: stop the runtime once. Additional calls are no-ops.

Trait Implementations

impl Clone for ClusterRuntimeHandle

fn clone(&self) -> ClusterRuntimeHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.