Struct SyncChannelManager 

pub struct SyncChannelManager { /* private fields */ }

Manager for sync channels to all peers

Automatically creates and manages persistent channels for each connected peer.

Implementations

impl SyncChannelManager

pub fn new( transport: Arc<dyn SyncTransport>, coordinator: Arc<AutomergeSyncCoordinator>, ) -> SyncChannelManager

Create a new channel manager

pub async fn get_channel( &self, peer_id: PublicKey, ) -> Result<Arc<SyncChannel>, Error>

Get or create a channel to a peer

pub async fn send_to_peer( &self, peer_id: PublicKey, batch: &SyncBatch, ) -> Result<(), Error>

Send batch to a peer through persistent channel

pub async fn broadcast(&self, batch: &SyncBatch) -> Result<(), Error>

Broadcast batch to all connected peers

pub async fn send_delta_sync( &self, peer_id: PublicKey, doc_key: &str, message: &Message, ) -> Result<usize, Error>

Send a delta sync message to a specific peer through persistent channel

Packages the message into a SyncBatch and sends it.

pub async fn send_state_snapshot( &self, peer_id: PublicKey, doc_key: &str, state_bytes: Vec<u8>, ) -> Result<usize, Error>

Send a state snapshot to a specific peer through persistent channel

pub async fn send_tombstone( &self, peer_id: PublicKey, tombstone_msg: &TombstoneSyncMessage, ) -> Result<usize, Error>

Send a tombstone to a specific peer through persistent channel

pub async fn send_tombstone_batch( &self, peer_id: PublicKey, tombstones: &[TombstoneSyncMessage], ) -> Result<usize, Error>

Send multiple tombstones to a specific peer through persistent channel

pub async fn broadcast_delta_sync( &self, doc_key: &str, message: &Message, ) -> Result<(), Error>

Broadcast a delta sync message to all connected peers

pub async fn broadcast_state_snapshot( &self, doc_key: &str, state_bytes: Vec<u8>, ) -> Result<(), Error>

Broadcast a state snapshot to all connected peers

pub async fn broadcast_tombstone( &self, tombstone_msg: &TombstoneSyncMessage, ) -> Result<(), Error>

Broadcast a tombstone to all connected peers

pub async fn remove_channel(&self, peer_id: &PublicKey)

Remove channel for a peer (e.g., on disconnect)

pub fn channel_count(&self) -> usize

Get number of active channels

pub fn stats(&self) -> ChannelManagerStats

Get statistics for all channels

pub async fn shutdown(&self)

Shutdown the manager and close all channels