Struct NativeSyncularClient 

pub struct NativeSyncularClient { /* private fields */ }

Implementations

impl NativeSyncularClient

pub fn builder(config: NativeClientConfig) -> NativeSyncularClientBuilder

pub fn open( config: SyncularClientConfig, ) -> Result<NativeSyncularClient, SyncularError>

pub fn open_native( config: NativeClientConfig, ) -> Result<NativeSyncularClient, SyncularError>

pub fn open_native_with_options( config: NativeClientConfig, options: NativeClientOptions, ) -> Result<NativeSyncularClient, SyncularError>

pub fn open_native_async_with_options( config: NativeClientConfig, options: NativeClientOptions, ) -> NativeClientOpenTask

pub fn open_with_options( config: SyncularClientConfig, options: NativeClientOptions, ) -> Result<NativeSyncularClient, SyncularError>

pub fn open_with_options_and_schema( config: SyncularClientConfig, options: NativeClientOptions, app_schema: AppSchema, ) -> Result<NativeSyncularClient, SyncularError>

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

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

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

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

pub fn enqueue_mutation_json( &self, mutation_json: &str, local_row_json: Option<&str>, ) -> Result<String, SyncularError>

pub fn enqueue_leased_mutation_json( &self, mutation_json: &str, local_row_json: Option<&str>, ) -> Result<String, SyncularError>

pub fn enqueue_yjs_update_json( &self, update_json: &str, ) -> Result<String, SyncularError>

pub fn enqueue_crdt_field_yjs_update_json( &self, request_json: &str, ) -> Result<String, SyncularError>

pub fn enqueue_crdt_field_text_json( &self, request_json: &str, ) -> Result<String, SyncularError>

pub fn enqueue_crdt_field_compaction_json( &self, request_json: &str, ) -> Result<String, SyncularError>

pub fn enqueue_encrypted_crdt_update_json( &self, request_json: &str, ) -> Result<String, SyncularError>

pub fn enqueue_encrypted_crdt_checkpoint_json( &self, request_json: &str, ) -> Result<String, SyncularError>

pub fn enqueue_resolve_conflict( &self, id: &str, resolution: &str, ) -> Result<String, SyncularError>

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

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

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

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

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

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

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

pub fn set_auth_headers( &mut self, headers: BTreeMap<String, String>, ) -> Result<(), SyncularError>

pub fn set_auth_headers_json( &mut self, headers_json: &str, ) -> Result<(), SyncularError>

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

pub fn set_subscriptions_json( &mut self, subscriptions_json: &str, ) -> Result<(), SyncularError>

pub fn force_subscriptions_bootstrap( &mut self, subscription_ids: Vec<String>, ) -> Result<usize, SyncularError>

pub fn force_subscriptions_bootstrap_json( &mut self, subscription_ids_json: &str, ) -> Result<String, SyncularError>

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

pub fn set_field_encryption_json( &mut self, config_json: &str, ) -> Result<(), SyncularError>

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

pub fn set_encrypted_crdt_json( &mut self, config_json: &str, ) -> Result<(), SyncularError>

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

pub fn set_blob_encryption_json( &mut self, config_json: &str, ) -> Result<(), SyncularError>

pub fn encryption_helper_json( &self, method: &str, args_json: &str, ) -> Result<String, SyncularError>

pub fn pause_sync_worker(&mut self) -> Result<(), SyncularError>

pub fn resume_sync_worker(&mut self) -> Result<(), SyncularError>

pub fn resume_from_background(&mut self) -> Result<String, SyncularError>

pub fn shutdown(&mut self) -> Result<(), SyncularError>

pub fn start_realtime_worker(&mut self) -> Result<(), SyncularError>

pub fn stop_realtime_worker(&mut self) -> Result<(), SyncularError>

pub fn sync_worker_running(&self) -> bool

pub fn join_presence( &mut self, scope_key: &str, metadata: Option<Value>, ) -> Result<(), SyncularError>

pub fn join_presence_handle( &mut self, scope_key: &str, metadata: Option<Value>, ) -> Result<NativePresenceHandle<'_>, SyncularError>

pub fn leave_presence(&mut self, scope_key: &str) -> Result<(), SyncularError>

pub fn update_presence_metadata( &mut self, scope_key: &str, metadata: Value, ) -> Result<(), SyncularError>

pub fn presence_json(&self, scope_key: &str) -> Result<String, SyncularError>

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

pub fn event_receiver(&self, capacity: usize) -> NativeEventSubscription

pub fn next_event(&self) -> Option<NativeEvent>

pub fn next_event_timeout(&self, timeout: Duration) -> Option<NativeEvent>

pub fn next_event_json(&self) -> Option<Result<String, SyncularError>>

pub fn next_event_json_timeout( &self, timeout: Duration, ) -> Option<Result<String, SyncularError>>

pub fn apply_mutation_json( &mut self, mutation_json: &str, local_row_json: Option<&str>, ) -> Result<String, SyncularError>

pub fn apply_leased_mutation_json( &mut self, mutation_json: &str, local_row_json: Option<&str>, ) -> Result<String, SyncularError>

pub fn open_crdt_field_json( &self, request_json: &str, ) -> Result<String, SyncularError>

pub fn apply_crdt_field_text_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn apply_crdt_field_yjs_update_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn materialize_crdt_field_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn crdt_document_snapshot_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn crdt_update_log_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn snapshot_crdt_field_state_vector_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn compact_crdt_field_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn apply_encrypted_crdt_update_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn apply_encrypted_crdt_checkpoint_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn list_table_json(&mut self, table: &str) -> Result<String, SyncularError>

pub fn query_json(&self, request_json: &str) -> Result<String, SyncularError>

pub fn store_blob_file_json( &mut self, path: &str, options_json: Option<&str>, ) -> Result<String, SyncularError>

pub fn retrieve_blob_file( &mut self, ref_json: &str, path: &str, ) -> Result<(), SyncularError>

pub fn retrieve_blob_file_with_options( &mut self, ref_json: &str, path: &str, options_json: Option<&str>, ) -> Result<(), SyncularError>

pub fn is_blob_local(&mut self, hash: &str) -> Result<bool, SyncularError>

pub fn process_blob_upload_queue_json( &mut self, ) -> Result<String, SyncularError>

pub fn blob_upload_queue_stats_json(&mut self) -> Result<String, SyncularError>

pub fn blob_cache_stats_json(&mut self) -> Result<String, SyncularError>

pub fn prune_blob_cache(&mut self, max_bytes: i64) -> Result<i64, SyncularError>

pub fn clear_blob_cache(&mut self) -> Result<(), SyncularError>

pub fn compact_storage_json( &mut self, options_json: Option<&str>, ) -> Result<String, SyncularError>

pub fn app_tables(&self) -> Vec<String>

pub fn app_tables_json(&self) -> Result<String, SyncularError>

pub fn app_table_metadata_json(&self) -> Result<String, SyncularError>

pub fn app_schema_state_json(&mut self) -> Result<String, SyncularError>

pub fn local_health_check_json(&mut self) -> Result<String, SyncularError>

pub fn export_local_support_bundle_json( &mut self, ) -> Result<String, SyncularError>

pub fn import_local_support_bundle_json( &mut self, bundle_json: &str, ) -> Result<String, SyncularError>

pub fn repair_local_health_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn reset_local_sync_state_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn register_query_json( &self, query_json: &str, ) -> Result<String, SyncularError>

pub fn unregister_query(&self, id: &str) -> Result<(), SyncularError>

pub fn observed_queries( &self, ) -> Result<Vec<NativeObservedQuery>, SyncularError>

pub fn observed_queries_json(&self) -> Result<String, SyncularError>

pub fn diagnostic_snapshot( &mut self, ) -> Result<NativeDiagnosticSnapshot, SyncularError>

pub fn diagnostic_snapshot_json(&mut self) -> Result<String, SyncularError>

pub fn outbox_summaries(&mut self) -> Result<Vec<OutboxSummary>, SyncularError>

pub fn outbox_summaries_json(&mut self) -> Result<String, SyncularError>

pub fn upsert_auth_lease_json( &mut self, lease_json: &str, ) -> Result<(), SyncularError>

pub fn issue_auth_lease_json( &mut self, request_json: &str, ) -> Result<String, SyncularError>

pub fn auth_lease_json( &mut self, lease_id: &str, ) -> Result<String, SyncularError>

pub fn active_auth_leases_json( &mut self, actor_id: Option<&str>, now_ms_value: i64, ) -> Result<String, SyncularError>

pub fn set_outbox_auth_lease_json( &mut self, client_commit_id: &str, provenance_json: Option<&str>, ) -> Result<(), SyncularError>

pub fn conflict_summaries( &mut self, ) -> Result<Vec<ConflictSummary>, SyncularError>

pub fn conflict_summaries_json(&mut self) -> Result<String, SyncularError>

pub fn resolve_conflict( &mut self, id: &str, resolution: &str, ) -> Result<(), SyncularError>

pub fn retry_conflict_keep_local( &mut self, id: &str, ) -> Result<String, SyncularError>

pub fn close(&mut self) -> Result<(), SyncularError>

Trait Implementations

impl Drop for NativeSyncularClient

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.