Trait SyncWorkerClientExt 

pub trait SyncWorkerClientExt {
    // Required methods
    fn apply_worker_mutation_json(
        &mut self,
        mutation_json: &str,
        local_row_json: Option<&str>,
    ) -> Result<String>;
    fn apply_worker_mutation(
        &mut self,
        mutation: SyncOperation,
        local_row: Option<Value>,
    ) -> Result<String>;

    // Provided methods
    fn apply_worker_leased_mutation_json(
        &mut self,
        _mutation_json: &str,
        _local_row_json: Option<&str>,
    ) -> Result<String> { ... }
    fn worker_current_row_json(
        &mut self,
        _table: &str,
        _row_id: &str,
    ) -> Result<Option<Value>> { ... }
    fn apply_worker_encrypted_crdt_update_json(
        &mut self,
        _request_json: &str,
    ) -> Result<WorkerLocalWriteReceipt> { ... }
    fn apply_worker_encrypted_crdt_checkpoint_json(
        &mut self,
        _request_json: &str,
    ) -> Result<Option<WorkerLocalWriteReceipt>> { ... }
    fn apply_worker_crdt_field_text_json(
        &mut self,
        _request_json: &str,
    ) -> Result<WorkerLocalWriteReceipt> { ... }
    fn compact_worker_crdt_field_json(
        &mut self,
        _request_json: &str,
    ) -> Result<Option<WorkerLocalWriteReceipt>> { ... }
    fn worker_crdt_field_event_payload_json(
        &mut self,
        _table: &str,
        _row_id: &str,
        _field: &str,
    ) -> Result<Option<Value>> { ... }
    fn worker_crdt_field_changed_row(
        &mut self,
        _table: &str,
        _row_id: &str,
        _field: &str,
        _client_commit_id: &str,
    ) -> Result<Option<SyncChangedRow>> { ... }
    fn worker_query_json(&mut self, _request_json: &str) -> Result<String> { ... }
    fn worker_compact_storage_json(
        &mut self,
        _options_json: Option<&str>,
    ) -> Result<String> { ... }
    fn worker_store_blob_file_json(
        &mut self,
        _path: &str,
        _options_json: Option<&str>,
    ) -> Result<String> { ... }
    fn worker_retrieve_blob_file_json(
        &mut self,
        _ref_json: &str,
        _path: &str,
        _options_json: Option<&str>,
    ) -> Result<String> { ... }
    fn worker_prune_blob_cache_json(
        &mut self,
        _max_bytes: i64,
    ) -> Result<String> { ... }
    fn worker_clear_blob_cache_json(&mut self) -> Result<String> { ... }
    fn worker_process_blob_upload_queue_json(
        &mut self,
    ) -> Result<Option<String>> { ... }
    fn worker_blob_upload_queue_stats_json(&mut self) -> Result<Option<String>> { ... }
    fn worker_next_outbox_retry_at_ms(&mut self) -> Result<Option<i64>> { ... }
    fn worker_next_blob_upload_retry_at_ms(&mut self) -> Result<Option<i64>> { ... }
}

Required Methods

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

fn apply_worker_mutation( &mut self, mutation: SyncOperation, local_row: Option<Value>, ) -> Result<String>

Provided Methods

fn apply_worker_leased_mutation_json( &mut self, _mutation_json: &str, _local_row_json: Option<&str>, ) -> Result<String>

fn worker_current_row_json( &mut self, _table: &str, _row_id: &str, ) -> Result<Option<Value>>

fn apply_worker_encrypted_crdt_update_json( &mut self, _request_json: &str, ) -> Result<WorkerLocalWriteReceipt>

fn apply_worker_encrypted_crdt_checkpoint_json( &mut self, _request_json: &str, ) -> Result<Option<WorkerLocalWriteReceipt>>

fn apply_worker_crdt_field_text_json( &mut self, _request_json: &str, ) -> Result<WorkerLocalWriteReceipt>

fn compact_worker_crdt_field_json( &mut self, _request_json: &str, ) -> Result<Option<WorkerLocalWriteReceipt>>

fn worker_crdt_field_event_payload_json( &mut self, _table: &str, _row_id: &str, _field: &str, ) -> Result<Option<Value>>

fn worker_crdt_field_changed_row( &mut self, _table: &str, _row_id: &str, _field: &str, _client_commit_id: &str, ) -> Result<Option<SyncChangedRow>>

fn worker_query_json(&mut self, _request_json: &str) -> Result<String>

fn worker_compact_storage_json( &mut self, _options_json: Option<&str>, ) -> Result<String>

fn worker_store_blob_file_json( &mut self, _path: &str, _options_json: Option<&str>, ) -> Result<String>

fn worker_retrieve_blob_file_json( &mut self, _ref_json: &str, _path: &str, _options_json: Option<&str>, ) -> Result<String>

fn worker_prune_blob_cache_json(&mut self, _max_bytes: i64) -> Result<String>

fn worker_clear_blob_cache_json(&mut self) -> Result<String>

fn worker_process_blob_upload_queue_json(&mut self) -> Result<Option<String>>

fn worker_blob_upload_queue_stats_json(&mut self) -> Result<Option<String>>

fn worker_next_outbox_retry_at_ms(&mut self) -> Result<Option<i64>>

fn worker_next_blob_upload_retry_at_ms(&mut self) -> Result<Option<i64>>

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<T> SyncWorkerClientExt for SyncularClient<DieselSqliteStore, T>

where T: SyncTransport + BlobTransport,

Available on crate feature native only.