Struct SyncChannel 

pub struct SyncChannel { /* private fields */ }

Persistent sync channel to a peer

Maintains a single bidirectional QUIC stream for all sync operations with automatic reconnection on failure.

Implementations

impl SyncChannel

pub async fn connect( transport: Arc<dyn SyncTransport>, peer_id: PublicKey, coordinator: Arc<AutomergeSyncCoordinator>, ) -> Result<SyncChannel, Error>

Create a new sync channel to a peer

Opens a bidirectional stream and spawns a receiver task. An optional CancellationToken can be provided; when cancelled, the receive loop exits promptly.

pub async fn connect_with_token( transport: Arc<dyn SyncTransport>, peer_id: PublicKey, coordinator: Arc<AutomergeSyncCoordinator>, cancel: Option<CancellationToken>, ) -> Result<SyncChannel, Error>

Create a new sync channel to a peer with an explicit cancellation token.

See connect for details.

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

Send a batch through this channel

Wire format (compatible with receive_sync_payload_from_stream):

[2 bytes: doc_key_len][N bytes: "batch"][1 byte: 0x07][4 bytes: batch_len][batch_bytes...]

pub async fn reconnect(&self) -> Result<(), Error>

Attempt to reconnect the channel

pub fn is_connected(&self) -> bool

Check if channel is connected

pub fn state(&self) -> ChannelState

Get channel state

pub fn peer_id(&self) -> PublicKey

Get peer ID

pub fn bytes_sent(&self) -> u64

Get total bytes sent

pub fn batches_sent(&self) -> u64

Get total batches sent

pub async fn close(&self)

Close the channel