Struct WebSocketSyncEngine 

pub struct WebSocketSyncEngine { /* private fields */ }

WebSocket-integrated sync engine

Implementations

impl WebSocketSyncEngine

pub fn new( storage: Storage, config: WebSocketIntegrationConfig, replica_id: ReplicaId, ) -> Self

Create a new WebSocket sync engine

pub async fn start(&self) -> Result<(), WebSocketIntegrationError>

Start the WebSocket sync engine

pub async fn stop(&self) -> Result<(), WebSocketIntegrationError>

Stop the WebSocket sync engine

pub async fn send_delta( &self, collection_id: String, crdt_type: CrdtType, delta: Vec<u8>, ) -> Result<(), WebSocketIntegrationError>

Send a CRDT delta to peers

pub fn sync_engine(&self) -> &Arc<SyncEngine<WebSocketClient>>

Get the underlying sync engine

pub fn websocket_client(&self) -> &Arc<WebSocketClient>

Get the WebSocket client

pub async fn is_running(&self) -> bool

Check if the engine is running

pub async fn is_connected(&self) -> bool

Get connection status