Struct DieselSqliteTx 

pub struct DieselSqliteTx<'a> { /* private fields */ }

Trait Implementations

impl SyncStoreTx for DieselSqliteTx<'_>

fn pending_outbox(&mut self, limit: i64) -> Result<Vec<OutboxCommit>>

fn requeue_stale_outbox(&mut self) -> Result<()>

fn mark_outbox_sending(&mut self, row_id: &str) -> Result<()>

fn mark_pushed_operation_server_versions( &mut self, outbox: &OutboxCommit, response: &PushCommitResponse, ) -> Result<()>

fn mark_outbox_acked( &mut self, row_id: &str, response: &PushCommitResponse, ) -> Result<()>

fn mark_outbox_failed( &mut self, row_id: &str, error: &str, response: &PushCommitResponse, ) -> Result<()>

fn mark_outbox_retry( &mut self, row_id: &str, error: &str, next_attempt_at: i64, failed: bool, ) -> Result<()>

fn insert_conflict( &mut self, outbox: &OutboxCommit, result: &OperationResult, ) -> Result<()>

fn upsert_auth_lease(&mut self, lease: &AuthLeaseRecord) -> Result<()>

fn auth_lease( &mut self, lease_id_value: &str, ) -> Result<Option<AuthLeaseRecord>>

fn active_auth_leases( &mut self, actor_id_value: Option<&str>, now_ms_value: i64, ) -> Result<Vec<AuthLeaseRecord>>

fn set_outbox_auth_lease( &mut self, client_commit_id_value: &str, provenance: Option<&AuthLeaseProvenance>, ) -> Result<()>

fn subscription_state( &mut self, state_id_value: &str, subscription_id_value: &str, ) -> Result<Option<SubscriptionState>>

fn subscription_states( &mut self, state_id_value: &str, ) -> Result<Vec<SubscriptionState>>

fn upsert_subscription_state(&mut self, state: &SubscriptionState) -> Result<()>

fn delete_subscription_state( &mut self, state_id_value: &str, subscription_id_value: &str, ) -> Result<()>

fn verified_root( &mut self, state_id_value: &str, subscription_id_value: &str, ) -> Result<Option<VerifiedRoot>>

fn verified_roots(&mut self, state_id_value: &str) -> Result<Vec<VerifiedRoot>>

fn upsert_verified_root(&mut self, root: &VerifiedRoot) -> Result<()>

fn delete_verified_root( &mut self, state_id_value: &str, subscription_id_value: &str, ) -> Result<()>

fn crdt_state_vector_hints( &mut self, table: &str, scopes: &ScopeValues, limit: i64, ) -> Result<Vec<CrdtStateVectorHint>>

fn clear_table_for_scopes( &mut self, table: &str, scopes: &ScopeValues, ) -> Result<()>

fn clear_synced_rows_for_scopes( &mut self, table: &str, scopes: &ScopeValues, ) -> Result<i64>

fn clear_table_for_scopes_preserving_local_crdt( &mut self, table: &str, scopes: &ScopeValues, ) -> Result<()>

fn current_row_json( &mut self, table: &str, row_id: &str, ) -> Result<Option<Value>>

fn upsert_row( &mut self, table: &str, row: &Value, fallback_version: Option<i64>, ) -> Result<()>

fn upsert_rows( &mut self, table: &str, rows: &[Value], fallback_version: Option<i64>, ) -> Result<()>

fn upsert_snapshot_chunk_rows( &mut self, table: &str, rows: &SnapshotChunkRows, fallback_version: Option<i64>, ) -> Result<()>

fn apply_change(&mut self, change: &SyncChange) -> Result<()>