Struct DieselSqliteStore 

pub struct DieselSqliteStore { /* private fields */ }

Implementations

impl DieselSqliteStore

pub fn open(path: &str) -> Result<DieselSqliteStore, SyncularError>

pub fn open_with_schema( path: &str, app_schema: AppSchema, ) -> Result<DieselSqliteStore, SyncularError>

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

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

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

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

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

pub fn record_command_history( &mut self, mutation_scope: &str, entries: &[CommandHistoryEntry], receipt: &MutationReceipt, ) -> Result<CommandHistoryRecord, SyncularError>

pub fn apply_syncular_mutations_with_command_history( &mut self, mutation_scope: &str, actor_id: Option<&str>, now_ms_value: i64, mutations: Vec<PendingSyncularMutation>, ) -> Result<MutationReceipt, SyncularError>

pub fn latest_command_history( &mut self, state: CommandHistoryState, ) -> Result<Option<CommandHistoryRecord>, SyncularError>

pub fn mark_command_history( &mut self, id: &str, state: CommandHistoryState, receipt: &MutationReceipt, ) -> Result<(), SyncularError>

pub fn read<'query, Q, Row>( &mut self, query: Q, ) -> Result<Vec<Row>, SyncularError>

where Q: LoadQuery<'query, SqliteConnection, Row>,

pub fn apply_local_operation( &mut self, operation: SyncOperation, local_row: Option<Value>, ) -> Result<String, SyncularError>

pub fn apply_local_operation_with_active_auth_lease( &mut self, actor_id: Option<&str>, now_ms_value: i64, operation: SyncOperation, local_row: Option<Value>, ) -> Result<String, SyncularError>

pub fn apply_syncular_mutations( &mut self, mutations: Vec<PendingSyncularMutation>, ) -> Result<MutationReceipt, SyncularError>

pub fn apply_syncular_mutations_with_active_auth_lease( &mut self, actor_id: Option<&str>, now_ms_value: i64, mutations: Vec<PendingSyncularMutation>, ) -> Result<MutationReceipt, SyncularError>

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

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

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

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

pub fn store_blob_bytes( &mut self, data: &[u8], mime_type: &str, enqueue_upload: bool, ) -> Result<BlobRef, SyncularError>

pub fn store_blob_body( &mut self, blob: &BlobRef, data: &[u8], enqueue_upload: bool, ) -> Result<(), SyncularError>

pub fn cache_blob_bytes( &mut self, blob: &BlobRef, data: &[u8], ) -> Result<(), SyncularError>

pub fn read_cached_blob( &mut self, hash: &str, ) -> Result<Option<Vec<u8>>, SyncularError>

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

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

pub fn pending_blob_uploads( &mut self, limit: i64, retry_now: bool, ) -> Result<Vec<PendingBlobUploadRow>, SyncularError>

pub fn mark_blob_uploading( &mut self, hash: &str, attempt_count: i32, ) -> Result<(), SyncularError>

pub fn mark_blob_upload_error( &mut self, hash: &str, status: &str, error: &str, next_attempt_at: i64, ) -> Result<(), SyncularError>

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

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

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

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

pub fn apply_crdt_field_yjs_update( &mut self, field: &CrdtField, update: YjsUpdateEnvelope, max_pending_updates: i64, ) -> Result<String, SyncularError>

pub fn crdt_document_snapshot( &mut self, field: &CrdtField, ) -> Result<CrdtDocumentSnapshot, SyncularError>

pub fn crdt_update_log( &mut self, field: &CrdtField, limit: i64, ) -> Result<Vec<CrdtUpdateLogEntry>, SyncularError>

pub fn compact_crdt_document( &mut self, field: &CrdtField, ) -> Result<CrdtDocumentSnapshot, SyncularError>

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

pub fn prune_crdt_update_log( &mut self, cutoff: i64, ) -> Result<i64, SyncularError>

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

pub fn encrypted_crdt_stream_stats( &mut self, partition_id: &str, stream_id: &str, ) -> Result<EncryptedCrdtStreamStats, SyncularError>

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

pub fn prune_encrypted_crdt_checkpoints( &mut self, keep_per_stream: i64, ) -> Result<i64, SyncularError>

pub fn compact_storage( &mut self, options: &StorageCompactionOptions, ) -> Result<StorageCompactionReport, SyncularError>

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

Trait Implementations

impl SyncStateStore for DieselSqliteStore

fn applied_migrations(&mut self) -> Result<Vec<AppliedMigration>, SyncularError>

fn app_schema_state( &mut self, _current_schema_version: i32, ) -> Result<AppSchemaState, SyncularError>

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

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

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

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

fn blob_health_summary( &mut self, ) -> Result<Option<BlobHealthSummary>, SyncularError>

fn crdt_health_summary( &mut self, ) -> Result<Option<CrdtHealthSummary>, SyncularError>

fn scoped_rows_health_summary( &mut self, subscriptions: &[SubscriptionSpec], ) -> Result<Option<ScopedRowsHealthSummary>, SyncularError>

fn clear_orphaned_synced_rows( &mut self, subscriptions: &[SubscriptionSpec], tables: &[String], ) -> Result<ScopedRowsHealthSummary, SyncularError>

fn resolve_conflict( &mut self, id_value: &str, resolution_value: &str, ) -> Result<(), SyncularError>

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

impl SyncStore for DieselSqliteStore

type Tx<'a> = DieselSqliteTx<'a>

fn transaction<T>( &mut self, f: impl FnOnce(&mut <DieselSqliteStore as SyncStore>::Tx<'_>) -> Result<T, SyncularError>, ) -> Result<T, SyncularError>

fn supports_sqlite_snapshot_artifacts(&self) -> bool

fn decode_sqlite_snapshot_artifact_rows( &self, table: &str, artifact_bytes: &[u8], ) -> Result<Vec<Value>, SyncularError>