Struct DistributedTdbStore 

pub struct DistributedTdbStore { /* private fields */ }

Distributed TDB Store

High-level interface for distributed RDF storage with integrated transaction coordination, deadlock detection, and replication.

Implementations

impl DistributedTdbStore

pub fn new(node_id: String, config: DistributedConfig) -> Self

Create a new Distributed TDB Store with no network transport configured.

Note: because no NetworkTransport is supplied, the underlying TransactionCoordinator and ReplicationManager cannot honestly reach any other node: commit_distributed_transaction() will fail with TdbError::DistributedTransportNotConfigured for every protocol rather than fabricating success. Use DistributedTdbStore::with_transport (with a real network-backed transport, or crate::consensus::transport::LoopbackSimulationTransport for single-node tests) to actually drive distributed commits.

pub fn with_transport( node_id: String, config: DistributedConfig, transport: Arc<dyn NetworkTransport>, ) -> Self

Create a new Distributed TDB Store backed by a real (or explicitly-simulated) NetworkTransport, shared by both the transaction coordinator and the replication manager. This is the constructor production code should use to actually drive distributed commits and replication.

pub async fn register_node( &mut self, node_id: &str, endpoint: &str, ) -> Result<()>

Register a node in the distributed system

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

Begin a distributed transaction

pub async fn begin_distributed_transaction_with_protocol( &mut self, protocol: CommitProtocol, ) -> Result<String>

Begin a distributed transaction with specific protocol

pub async fn commit_distributed_transaction( &mut self, txn_id: &str, ) -> Result<bool>

Commit a distributed transaction

pub async fn abort_distributed_transaction( &mut self, txn_id: &str, ) -> Result<()>

Abort a distributed transaction

pub async fn execute_saga(&mut self, saga: SagaOrchestrator) -> Result<bool>

Create and execute a saga

pub fn node_id(&self) -> &str

Get node ID

pub fn active_transaction_count(&self) -> usize

Get active transaction count

pub fn stats(&self) -> DistributedStoreStats

Get statistics

pub fn coordinator_stats(&self) -> CoordinatorStats

Get coordinator statistics

pub fn replication_stats(&self) -> Option<ReplicationStats>

Get replication statistics (if enabled)

pub async fn check_health(&self) -> Result<HealthStatus>

Check system health