Struct ClusterNode 

pub struct ClusterNode { /* private fields */ }

Cluster node implementation

Implementations

impl ClusterNode

pub async fn new(config: NodeConfig) -> Result<Self>

Create a new cluster node

pub async fn start(&mut self) -> Result<()>

Start the cluster node

pub async fn stop(&mut self) -> Result<()>

Stop the cluster node

pub async fn is_leader(&self) -> bool

Check if this node is the leader

pub async fn current_term(&self) -> u64

Get current consensus term

pub async fn insert_triple( &self, subject: &str, predicate: &str, object: &str, ) -> Result<RdfResponse>

Insert a triple through distributed consensus

pub async fn delete_triple( &self, subject: &str, predicate: &str, object: &str, ) -> Result<RdfResponse>

Delete a triple through distributed consensus

pub async fn clear_store(&self) -> Result<RdfResponse>

Clear all triples through distributed consensus

pub async fn begin_transaction(&self) -> Result<String>

Begin a distributed transaction

pub async fn commit_transaction(&self, tx_id: &str) -> Result<RdfResponse>

Commit a distributed transaction

pub async fn rollback_transaction(&self, tx_id: &str) -> Result<RdfResponse>

Rollback a distributed transaction

pub async fn query_triples( &self, subject: Option<&str>, predicate: Option<&str>, object: Option<&str>, ) -> Vec<(String, String, String)>

Query triples (can be done on any node)

pub async fn query_sparql(&self, sparql: &str) -> Result<Vec<String>>

Execute SPARQL query using distributed query processing

pub async fn query_sparql_bindings( &self, sparql: &str, ) -> Result<Vec<ResultBinding>>

Execute SPARQL query and return structured results

pub async fn get_query_statistics(&self) -> Result<HashMap<String, QueryStats>>

Get query execution statistics

pub async fn clear_query_cache(&self) -> Result<()>

Clear query cache

pub async fn len(&self) -> usize

Get the number of triples in the store

pub async fn is_empty(&self) -> bool

Check if the store is empty

pub async fn add_cluster_node( &mut self, node_id: OxirsNodeId, address: SocketAddr, ) -> Result<()>

Add a new node to the cluster

pub async fn remove_cluster_node(&mut self, node_id: OxirsNodeId) -> Result<()>

Remove a node from the cluster

pub async fn get_status(&self) -> ClusterStatus

Get comprehensive cluster status

pub async fn add_node_with_consensus( &mut self, node_id: OxirsNodeId, address: SocketAddr, ) -> Result<()>

Add a new node to the cluster using consensus protocol

pub async fn remove_node_with_consensus( &mut self, node_id: OxirsNodeId, ) -> Result<()>

Remove a node from the cluster using consensus protocol

pub async fn graceful_shutdown(&mut self) -> Result<()>

Gracefully shutdown this node

pub async fn transfer_leadership( &mut self, target_node: OxirsNodeId, ) -> Result<()>

Transfer leadership to another node

pub async fn force_evict_node(&mut self, node_id: OxirsNodeId) -> Result<()>

Force evict a non-responsive node

pub async fn check_cluster_health(&self) -> Result<Vec<NodeHealthStatus>>

Check health of all peer nodes

pub async fn attempt_recovery(&mut self) -> Result<()>

Attempt recovery from partition or failure

pub fn id(&self) -> OxirsNodeId

Get the node ID

pub async fn count_triples(&self) -> Result<usize>

Count triples in the store

pub async fn is_active(&self) -> Result<bool>

Check if the node is active (running and not isolated)

pub async fn isolate_network(&self) -> Result<()>

Isolate the node from network (simulate network partition)

pub async fn restore_network(&self) -> Result<()>

Restore network connectivity

pub async fn enable_byzantine_mode(&self) -> Result<()>

Enable Byzantine behavior (for testing)

pub async fn is_byzantine(&self) -> Result<bool>

Check if node is in Byzantine mode

pub fn region_manager(&self) -> Option<&Arc<RegionManager>>

Get multi-region manager (if configured)

pub fn is_multi_region_enabled(&self) -> bool

Check if multi-region deployment is enabled

pub fn get_region_id(&self) -> Option<String>

Get current node’s region ID

pub fn get_availability_zone_id(&self) -> Option<String>

Get current node’s availability zone ID

pub async fn get_regional_peers(&self) -> Result<Vec<OxirsNodeId>>

Get nodes in the same region

pub async fn get_regional_leader_candidates(&self) -> Result<Vec<OxirsNodeId>>

Get optimal leader candidates considering region affinity

pub async fn get_cross_region_replication_targets(&self) -> Result<Vec<String>>

Calculate cross-region replication targets

pub async fn monitor_region_latencies(&self) -> Result<()>

Monitor inter-region latencies and update metrics

pub async fn get_region_health(&self, region_id: &str) -> Result<RegionHealth>

Get region health status

pub async fn perform_region_failover( &self, failed_region: &str, target_region: &str, ) -> Result<()>

Perform region failover operation

pub async fn get_region_topology(&self) -> Result<RegionTopology>

Get multi-region topology information

pub async fn add_node_to_region( &self, node_id: OxirsNodeId, region_id: String, availability_zone_id: String, data_center: Option<String>, rack: Option<String>, ) -> Result<()>

Add a node to a specific region and availability zone

pub fn conflict_resolver(&self) -> &Arc<ConflictResolver>

Get conflict resolver instance

pub async fn get_vector_clock(&self) -> VectorClock

Get current vector clock value

pub async fn update_vector_clock(&self, received_clock: &VectorClock)

Update vector clock with received clock

pub async fn create_timestamped_operation( &self, operation: RdfOperation, priority: u32, ) -> TimestampedOperation

Create a timestamped operation with current vector clock

pub async fn detect_operation_conflicts( &self, operations: &[TimestampedOperation], ) -> Result<Vec<ConflictType>>

Detect conflicts in a batch of operations

pub async fn resolve_operation_conflicts( &self, conflicts: &[ConflictType], ) -> Result<Vec<ResolutionResult>>

Resolve conflicts using configured strategies

pub async fn submit_conflict_aware_operation( &self, operation: RdfOperation, priority: u32, ) -> Result<RdfResponse>

Submit an operation for conflict-aware processing

pub async fn get_conflict_resolution_statistics(&self) -> ResolutionStatistics

Get conflict resolution statistics

Trait Implementations

impl Debug for ClusterNode

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.