Struct GeoReplicationManager 

pub struct GeoReplicationManager { /* private fields */ }

Geo-Replication Manager.

Manages cross-region event replication with CRDT conflict resolution and HLC-based causal ordering.

Implementations

impl GeoReplicationManager

pub fn new(config: GeoReplicationConfig) -> Self

Create a new geo-replication manager.

pub fn region_id(&self) -> &str

Get this region’s ID.

pub fn hlc(&self) -> &Arc<HybridLogicalClock>

Get the HLC instance.

pub fn resolver(&self) -> &Arc<CrdtResolver>

Get the CRDT resolver.

pub fn stamp_event(&self, event_id: &str, event_data: Value) -> ReplicatedEvent

Stamp a new local event with an HLC timestamp.

pub fn queue_for_replication(&self, event: &ReplicatedEvent)

Queue an event for replication to all peers.

pub fn drain_outbound( &self, peer_region: &str, max_batch: usize, ) -> Vec<ReplicatedEvent>

Drain the outbound buffer for a specific peer.

pub fn receive_sync(&self, request: &GeoSyncRequest) -> GeoSyncResponse

Receive events from a peer region.

Applies CRDT conflict resolution and returns the sync response.

pub fn set_peer_health(&self, peer_region: &str, health: PeerHealth)

Update a peer’s health status.

pub fn peer_health(&self, peer_region: &str) -> PeerHealth

Get a peer’s health status.

pub fn peers(&self) -> &[PeerRegion]

Get all peers.

pub fn sync_interval(&self) -> Duration

Get sync interval.

pub fn batch_size(&self) -> usize

Get batch size.

pub fn build_sync_request(&self, peer_region: &str) -> Option<GeoSyncRequest>

Build a sync request for a specific peer.

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

Select the best failover region (lowest replication lag, healthy).

pub fn status(&self) -> GeoReplicationStatus

Get full replication status.