Struct SyncWorker 

pub struct SyncWorker { /* private fields */ }

Implementations

impl SyncWorker

pub fn start<S, T>(client: SyncularClient<S, T>) -> Self

where S: SyncStore + SyncStateStore + Send + 'static, T: SyncTransport + SyncAuthHeaderStore + Send + 'static, SyncularClient<S, T>: SyncWorkerClientExt,

pub fn start_with_config<S, T>( client: SyncularClient<S, T>, config: SyncWorkerConfig, ) -> Self

where S: SyncStore + SyncStateStore + Send + 'static, T: SyncTransport + SyncAuthHeaderStore + Send + 'static, SyncularClient<S, T>: SyncWorkerClientExt,

pub fn trigger_sync(&self) -> Result<()>

pub fn trigger_sync_websocket(&self) -> Result<()>

pub fn trigger_handle(&self) -> SyncWorkerTrigger

pub fn subscribe_events(&self, capacity: usize) -> SyncWorkerEventSubscription

pub fn event_source(&self) -> SyncWorkerEventSubscription

pub fn enqueue_sync_now(&self, command_id: String) -> Result<()>

pub fn enqueue_sync_websocket(&self, command_id: String) -> Result<()>

pub fn enqueue_mutation_json( &self, command_id: String, mutation_json: String, local_row_json: Option<String>, auto_sync: bool, ) -> Result<()>

pub fn enqueue_leased_mutation_json( &self, command_id: String, mutation_json: String, local_row_json: Option<String>, auto_sync: bool, ) -> Result<()>

pub fn enqueue_yjs_update_json( &self, command_id: String, update_json: String, auto_sync: bool, ) -> Result<()>

pub fn enqueue_crdt_field_text_json( &self, command_id: String, request_json: String, auto_sync: bool, ) -> Result<()>

pub fn enqueue_crdt_field_compaction_json( &self, command_id: String, request_json: String, auto_sync: bool, ) -> Result<()>

pub fn enqueue_encrypted_crdt_update_json( &self, command_id: String, request_json: String, auto_sync: bool, ) -> Result<()>

pub fn enqueue_encrypted_crdt_checkpoint_json( &self, command_id: String, request_json: String, auto_sync: bool, ) -> Result<()>

pub fn enqueue_conflict_resolution( &self, command_id: String, conflict_id: String, resolution: String, auto_sync: bool, ) -> Result<()>

pub fn enqueue_refresh_snapshot_json( &self, command_id: String, request_json: String, ) -> Result<()>

pub fn enqueue_compact_storage_json( &self, command_id: String, options_json: Option<String>, ) -> Result<()>

pub fn enqueue_store_blob_file_json( &self, command_id: String, path: String, options_json: Option<String>, ) -> Result<()>

pub fn enqueue_retrieve_blob_file_json( &self, command_id: String, ref_json: String, path: String, options_json: Option<String>, ) -> Result<()>

pub fn enqueue_process_blob_upload_queue( &self, command_id: String, ) -> Result<()>

pub fn enqueue_prune_blob_cache( &self, command_id: String, max_bytes: i64, ) -> Result<()>

pub fn enqueue_clear_blob_cache(&self, command_id: String) -> Result<()>

pub fn set_auth_headers(&self, headers: SyncAuthHeaders) -> Result<()>

pub fn set_subscriptions( &self, subscriptions: Vec<SubscriptionSpec>, ) -> Result<()>

pub fn set_field_encryption( &self, encryption: Option<FieldEncryption>, ) -> Result<()>

pub fn set_encrypted_crdt( &self, encryption: Option<EncryptedCrdt>, ) -> Result<()>

pub fn set_blob_encryption( &self, encryption: Option<BlobEncryption>, ) -> Result<()>

pub fn recv_event_timeout(&self, timeout: Duration) -> Option<SyncWorkerEvent>

pub fn recv_result_timeout( &self, timeout: Duration, ) -> Option<Result<SyncReport>>

pub fn request_stop(&self) -> Result<()>

pub fn join(&mut self) -> Result<()>

pub fn stop(self) -> Result<()>

Trait Implementations

impl Drop for SyncWorker

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.