Struct SyncServer 

pub struct SyncServer { /* private fields */ }

Available on crate features sync and sync-http only.

Server-side sync handler.

Processes incoming sync requests from remote peers. Framework-agnostic — consumers create web handlers that delegate to this struct’s methods.

The server manages its own ChangePoller for serving pull requests and delegates push handling to RemoteChangeApplier.

Implementations

impl SyncServer

pub fn new(db: Arc<PulseDB>, config: SyncConfig) -> Self

Creates a new SyncServer for the given database.

pub fn instance_id(&self) -> InstanceId

Returns the server’s instance ID.

pub fn handle_handshake( &self, request: HandshakeRequest, ) -> Result<HandshakeResponse, SyncError>

Handles a handshake request.

pub fn handle_push( &self, changes: Vec<SyncChange>, ) -> Result<PushResponse, SyncError>

Handles a push request — applies remote changes locally.

pub fn handle_pull( &self, request: PullRequest, ) -> Result<PullResponse, SyncError>

Handles a pull request — serves local changes to the remote peer.

pub fn handle_health(&self) -> Result<(), SyncError>

Handles a health check.

pub fn handle_handshake_bytes(&self, body: &[u8]) -> Result<Vec<u8>, SyncError>

Handles a handshake from raw bincode bytes.

pub fn handle_push_bytes(&self, body: &[u8]) -> Result<Vec<u8>, SyncError>

Handles a push from raw bincode bytes.

pub fn handle_pull_bytes(&self, body: &[u8]) -> Result<Vec<u8>, SyncError>

Handles a pull from raw bincode bytes.