Crate oxirs_cluster

Expand description

§OxiRS Cluster

Status: Beta Release (v0.1.0-beta.1) Stability: Public APIs are stable. Production-ready with comprehensive testing.

Raft-backed distributed dataset for high availability and horizontal scaling.

This crate provides distributed storage capabilities using Raft consensus with multi-region support, Byzantine fault tolerance, and advanced replication strategies.

§Features

Raft Consensus: Production-ready Raft implementation using openraft
Distributed RDF Storage: Scalable, consistent RDF triple storage
Automatic Failover: Leader election and automatic recovery
Node Discovery: Multiple discovery mechanisms (static, DNS, multicast)
Replication Management: Configurable replication strategies
SPARQL Support: Distributed SPARQL query execution
Transaction Support: Distributed ACID transactions

§Example

use oxirs_cluster::{ClusterNode, NodeConfig};
use std::net::SocketAddr;

let config = NodeConfig {
    node_id: 1,
    address: "127.0.0.1:8080".parse()?,
    data_dir: "./data".to_string(),
    peers: vec![2, 3],
    discovery: None,
    replication_strategy: None,
    region_config: None,
    use_bft: false,
};

let mut node = ClusterNode::new(config).await?;
node.start().await?;

// Insert data through consensus
node.insert_triple(
    "<http://example.org/subject>",
    "<http://example.org/predicate>",
    "\"object\"")
.await?;

Re-exports§

pub use error::ClusterError;
pub use error::Result;
pub use failover::FailoverConfig;
pub use failover::FailoverManager;
pub use failover::FailoverStrategy;
pub use failover::RecoveryAction;
pub use health_monitor::HealthMonitor;
pub use health_monitor::HealthMonitorConfig;
pub use health_monitor::NodeHealth;
pub use health_monitor::SystemMetrics;
pub use consensus::ConsensusError;
pub use discovery::DiscoveryError;
pub use replication::ReplicationError;

Modules§

adaptive_leader_election: Adaptive Leader Election Tuning
advanced_partitioning: Advanced Partitioning Strategies
advanced_storage: Advanced Storage Backend
alerting: Alerting System Framework
auto_scaling: Automated Horizontal Scaling
backup_restore: Backup and Restore
circuit_breaker: Circuit Breaker Pattern
conflict_resolution: Advanced Conflict Resolution for Distributed Operations
consensus: Consensus Protocol
crash_recovery: Comprehensive Crash Recovery
data_rebalancing: Automatic Data Rebalancing
disaster_recovery: Disaster Recovery System
discovery: Node Discovery
distributed_query: Distributed Query Processing Module
distributed_tracing: Distributed Tracing with OpenTelemetry Integration
edge_computing: Edge Computing Integration for Distributed RDF Storage
enhanced_node_discovery: Enhanced Node Discovery
enhanced_snapshotting: Enhanced Snapshotting Module
error: Error types for the OxiRS cluster module
failover: Automated Failover System
federation: Advanced Federation Features
health_monitor: Health Monitoring and Failure Detection
health_monitoring: Enhanced Cluster Health Monitoring
memory_optimization: Memory optimization module for distributed RDF storage
merkle_tree: Merkle Tree Data Integrity Verification
mvcc: Multi-Version Concurrency Control (MVCC) implementation for OxiRS cluster
mvcc_storage: Version-aware storage backend for MVCC
network: Network Communication Layer
node_lifecycle: Node Lifecycle Management
node_status_tracker: Node Status Tracking with State Machine
operational_transformation: Enhanced Conflict Resolution with Operational Transformation
optimization: Storage and Serialization Optimization Module
partition_detection: Network Partition Detection and Auto-Healing
performance_metrics: Comprehensive Performance Metrics
performance_monitor: Performance Monitoring and Validation for OxiRS Cluster
raft: Raft Consensus Implementation
raft_optimization: Raft Consensus Optimization
raft_profiling: Raft Consensus Profiling Integration
raft_state: Raft State Machine Implementation
range_partitioning: Range-Based Partitioning Module
read_replica: Read Replica Support
region_manager: Multi-Region Deployment Manager
replication: Data Replication
replication_lag_monitor: Replication Lag Monitoring and Alerting
rolling_upgrade: Rolling Upgrade Support
security: Security and Authentication Module
serialization: Advanced Serialization Module
shard: Sharding with semantic-aware partitioning
shard_manager: Shard manager for coordinating distributed shards
shard_migration: Shard Migration Module
shard_routing: Shard routing for distributed query execution
split_brain_prevention: Split-Brain Prevention
storage: Distributed storage implementation for Raft consensus
strong_consistency: Strong Consistency Guarantees
tls: TLS Communication and Encryption Module
transaction: Cross-shard transaction support with Two-Phase Commit (2PC) optimization
transaction_optimizer: Optimizations for Two-Phase Commit protocol
visualization_dashboard: Visualization Dashboard
zero_downtime_migration: Zero-Downtime Migrations

Structs§

ClusterNode: Cluster node implementation
ClusterStatus: Comprehensive cluster status information
DistributedStore: Distributed RDF store (simplified interface)
EdgeComputingConfig: Edge computing configuration
MultiRegionConfig: Multi-region deployment configuration
NodeConfig: Cluster node configuration
RegionStatus: Multi-region status information

Crate oxirs_cluster

Crate oxirs_cluster Copy item path

§OxiRS Cluster

§Features

§Example

Re-exports§

Modules§

Structs§

Crate oxirs_cluster