Struct SynchronizationManager 

pub struct SynchronizationManager { /* private fields */ }

Manager for distributed schema synchronization.

Implementations

impl SynchronizationManager

pub fn new(node_id: NodeId, table: SymbolTable) -> Self

Create a new synchronization manager.

pub fn set_resolution_strategy(&mut self, strategy: ConflictResolution)

Set the conflict resolution strategy.

pub fn add_listener(&mut self, listener: Arc<dyn EventListener>)

Add an event listener.

pub fn register_node(&mut self, node_id: NodeId)

Register a remote node.

pub fn table(&self) -> &SymbolTable

Get the current symbol table.

pub fn table_mut(&mut self) -> &mut SymbolTable

Get a mutable reference to the symbol table.

pub fn pending_events(&self) -> Vec<SyncEvent>

Get pending events for broadcasting.

pub fn clear_pending_events(&mut self)

Clear pending events (after successful broadcast).

pub fn statistics(&self) -> &SyncStatistics

Get synchronization statistics.

pub fn add_domain(&mut self, domain: DomainInfo) -> Result<(), AdapterError>

Add a domain and generate sync event.

pub fn add_predicate( &mut self, predicate: PredicateInfo, ) -> Result<(), AdapterError>

Add a predicate and generate sync event.

pub fn remove_domain(&mut self, name: &str) -> Result<(), AdapterError>

Remove a domain and generate sync event.

pub fn apply_event( &mut self, event: SyncEvent, ) -> Result<ApplyResult, AdapterError>

Apply a sync event from another node.

pub fn synchronize<P: SyncProtocol>( &mut self, protocol: &P, ) -> Result<(), AdapterError>

Synchronize with another node using a protocol.