Trait SyncWorkerClientExt 

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

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

Required Methods

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

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

Provided Methods

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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.