Struct HttpSyncTransport 

pub struct HttpSyncTransport { /* private fields */ }

Available on crate features sync and sync-http only.

HTTP-based sync transport using reqwest.

Communicates with a remote PulseDB sync server over HTTP using bincode-serialized request/response bodies.

Endpoints

Method	Path	Request	Response
POST	/sync/handshake	HandshakeRequest	HandshakeResponse
POST	/sync/push	Vec<SyncChange>	PushResponse
POST	/sync/pull	PullRequest	PullResponse
GET	/sync/health	(none)	200 OK

Implementations

impl HttpSyncTransport

pub fn new(base_url: impl Into<String>) -> Self

Creates a new HTTP transport pointing at the given base URL.

The URL should not include a trailing slash. Example: "http://localhost:3000" or "https://api.example.com"

pub fn with_auth(base_url: impl Into<String>, token: impl Into<String>) -> Self

Creates a new HTTP transport with Bearer token authentication.

The token is sent as Authorization: Bearer {token} on every request.

Trait Implementations

impl SyncTransport for HttpSyncTransport

fn handshake<'life0, 'async_trait>( &'life0 self, request: HandshakeRequest, ) -> Pin<Box<dyn Future<Output = Result<HandshakeResponse, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Perform a handshake with the remote peer.

fn push_changes<'life0, 'async_trait>( &'life0 self, changes: Vec<SyncChange>, ) -> Pin<Box<dyn Future<Output = Result<PushResponse, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Push local changes to the remote peer.

fn pull_changes<'life0, 'async_trait>( &'life0 self, request: PullRequest, ) -> Pin<Box<dyn Future<Output = Result<PullResponse, SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Pull changes from the remote peer.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check if the remote peer is reachable.