Struct SyncClient 

pub struct SyncClient { /* private fields */ }

Implementations

impl SyncClient

pub fn new(db: Arc<Database>, nats_url: &str, tenant_id: &str) -> Self

pub async fn ensure_connected(&self) -> Result<Client, String>

Lazily connect to NATS, reuse existing connection. Returns cloned Client (cheap — Arc internally) so the mutex is not held during NATS ops. Returns Err with connection error message if NATS is unreachable.

pub async fn reconnect(&self)

Drop existing connection and reconnect.

pub async fn is_connected(&self) -> bool

pub fn db(&self) -> &Database

pub fn has_pending_push_changes(&self) -> Result<bool, Error>

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

pub async fn pull( &self, policies: &ConflictPolicies, ) -> Result<ApplyResult, Error>

Pull with explicit policies (frozen test contract, library consumers).

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

Pull using internally configured conflict policies (used by CLI).

pub async fn initial_sync( &self, policies: &ConflictPolicies, ) -> Result<ApplyResult, Error>

Initial sync using explicit policies (frozen test contract).

pub fn push_watermark(&self) -> u64

pub fn pull_watermark(&self) -> u64

pub fn tenant_id(&self) -> &str

pub fn nats_url(&self) -> &str

pub fn set_table_direction(&self, table: &str, direction: SyncDirection)

pub fn set_conflict_policy(&self, table: &str, policy: ConflictPolicy)

pub fn set_default_conflict_policy(&self, policy: ConflictPolicy)