Struct ClusterService 

pub struct ClusterService { /* private fields */ }

Native coordinator cluster service.

Wraps ruvector’s ClusterManager and syncs discovered nodes into the kernel’s universal ClusterMembership tracker.

Implementations

impl ClusterService

pub fn new( config: ClusterNetworkConfig, node_id: String, discovery: Box<dyn DiscoveryService>, membership: Arc<ClusterMembership>, ) -> Result<Self, ClusterError>

Create a new cluster service.

membership is the kernel’s universal peer tracker that all platforms share. The ClusterService syncs ruvector native node state into it.

pub fn with_defaults( node_id: String, membership: Arc<ClusterMembership>, ) -> Result<Self, ClusterError>

Create with default config and static (empty) discovery.

pub fn sync_to_membership(&self)

Sync ruvector’s native node list into the kernel’s ClusterMembership tracker.

Converts ruvector ClusterNode entries into kernel PeerNode entries, mapping SocketAddr → String and NodeStatus → NodeState.

Prefer the mesh peer-event path (Self::apply_mesh_peer_event / Self::spawn_mesh_peer_listener) for live membership; this pull-based method remains for bootstrap and fallback.

pub fn apply_mesh_peer_event( &self, event: &MeshPeerEvent, ) -> Result<bool, ClusterError>

Apply one mesh peer event: membership (atomic) + ruvector manager.

Membership is updated synchronously; manager add_node / remove_node are best-effort fire-and-forget via the runtime (call from async context via Self::apply_mesh_peer_event_async when manager updates must complete).

pub async fn apply_mesh_peer_event_async( &self, event: &MeshPeerEvent, ) -> Result<bool, ClusterError>

Apply mesh peer event and await ruvector manager join/leave.

pub fn spawn_mesh_peer_listener(self: &Arc<Self>, rx: Receiver<MeshPeerEvent>)

Subscribe to the mesh peer-event stream and keep membership + ruvector manager aligned with live mesh state (WEFT-120).

Idempotent: only one listener task is spawned per service.

pub fn mesh_listener_started(&self) -> bool

Whether a mesh peer-event listener is attached.

pub fn membership(&self) -> &Arc<ClusterMembership>

Shared membership handle (tests / boot introspection).

pub fn config(&self) -> &ClusterNetworkConfig

Get the cluster network configuration.

pub fn manager(&self) -> &ClusterManager

Get the underlying cluster manager (for advanced operations).

pub fn stats(&self) -> ClusterStats

Get cluster statistics.

pub fn list_shards(&self) -> Vec<ShardInfo>

List all shards.

pub fn list_nodes(&self) -> Vec<ClusterNode>

List all ruvector nodes.

Trait Implementations

impl SystemService for ClusterService

fn name(&self) -> &str

Human-readable service name.

fn service_type(&self) -> ServiceType

Service type category.

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start the service.

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop the service.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = HealthStatus> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Perform a health check.

fn health_detail(&self) -> Option<String>

Optional operator-facing detail (metrics, endpoints, …).

fn liveness_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ProbeResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Liveness probe (K2b-G2, os-patterns).

fn readiness_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ProbeResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Readiness probe (K2b-G2, os-patterns).