Struct SyncEngine 

pub struct SyncEngine { /* private fields */ }

Sync engine for managing real-time synchronization

Implementations

impl SyncEngine

pub fn new(event_bus: Arc<EventBus>) -> Self

Create a new sync engine

pub fn subscribe( &self, workspace_id: Uuid, client_id: Uuid, ) -> Result<Receiver<ChangeEvent>>

Subscribe a client to a workspace

pub fn unsubscribe(&self, workspace_id: Uuid, client_id: Uuid) -> Result<()>

Unsubscribe a client from a workspace

pub fn publish_change(&self, event: ChangeEvent) -> Result<()>

Publish a change event

pub fn get_state(&self, workspace_id: Uuid) -> Option<SyncState>

Get current state for a workspace

pub fn update_state(&self, workspace_id: Uuid, new_state: Value) -> Result<()>

Update state for a workspace

pub fn get_connections(&self, workspace_id: Uuid) -> Vec<Uuid>

Get connected clients for a workspace

pub fn connection_count(&self) -> usize

Get total number of connections

pub fn has_connections(&self, workspace_id: Uuid) -> bool

Check if a workspace has any active connections

pub fn cleanup_inactive(&self)

Clean up inactive workspaces (no connections)