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 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.