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.

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.