menu

sync_engine_drift.dart

sync_engine_drift library

Drift-backed persistence support for sync_engine.

Classes

$$LwwFrontierEntriesTableAnnotationComposer
$$LwwFrontierEntriesTableFilterComposer
$$LwwFrontierEntriesTableOrderingComposer
$$LwwFrontierEntriesTableTableManager
$$ReplicaAcknowledgementsTableAnnotationComposer
$$ReplicaAcknowledgementsTableFilterComposer
$$ReplicaAcknowledgementsTableOrderingComposer
$$ReplicaAcknowledgementsTableTableManager
$$SyncEntityTableTableAnnotationComposer
$$SyncEntityTableTableFilterComposer
$$SyncEntityTableTableOrderingComposer
$$SyncEntityTableTableTableManager
$LwwFrontierEntriesTable
$ReplicaAcknowledgementsTable
$SyncDriftDatabaseManager
$SyncEntityTableTable
DriftSyncOutbox: Durable outbox backed by the same Drift database as local sync storage.
DriftSyncStorage: Drift storage using reject-on-dominance semantics: a causally stale save is ignored so it cannot regress a newer durable value.
LwwFrontierEntries: Persisted causally-undominated LWW candidates for safe acknowledgement pruning.
LwwFrontierEntriesCompanion
LwwFrontierEntry
ReplicaAcknowledgementRow
ReplicaAcknowledgements: Per-entity, per-replica acknowledgement durable state.
ReplicaAcknowledgementsCompanion
SyncDriftDatabase: Database containing the durable sync rows and replica acknowledgements.
SyncEntityTable: Base persisted shape for a synchronized entity.
SyncEntityTableCompanion
SyncEntityTableData

Typedefs

$$LwwFrontierEntriesTableCreateCompanionBuilder = LwwFrontierEntriesCompanion Function({required String entityId, required String entityType, required String nodeId, Value<int> rowid, required String timestamp})
$$LwwFrontierEntriesTableProcessedTableManager = ProcessedTableManager<_$SyncDriftDatabase, $LwwFrontierEntriesTable, LwwFrontierEntry, $$LwwFrontierEntriesTableFilterComposer, $$LwwFrontierEntriesTableOrderingComposer, $$LwwFrontierEntriesTableAnnotationComposer, $$LwwFrontierEntriesTableCreateCompanionBuilder, $$LwwFrontierEntriesTableUpdateCompanionBuilder, (LwwFrontierEntry, BaseReferences<_$SyncDriftDatabase, $LwwFrontierEntriesTable, LwwFrontierEntry>), LwwFrontierEntry, PrefetchHooks Function()>
$$LwwFrontierEntriesTableUpdateCompanionBuilder = LwwFrontierEntriesCompanion Function({Value<String> entityId, Value<String> entityType, Value<String> nodeId, Value<int> rowid, Value<String> timestamp})
$$ReplicaAcknowledgementsTableCreateCompanionBuilder = ReplicaAcknowledgementsCompanion Function({required String acknowledgedClock, required String entityId, required String entityType, required String nodeId, Value<int> rowid})
$$ReplicaAcknowledgementsTableProcessedTableManager = ProcessedTableManager<_$SyncDriftDatabase, $ReplicaAcknowledgementsTable, ReplicaAcknowledgementRow, $$ReplicaAcknowledgementsTableFilterComposer, $$ReplicaAcknowledgementsTableOrderingComposer, $$ReplicaAcknowledgementsTableAnnotationComposer, $$ReplicaAcknowledgementsTableCreateCompanionBuilder, $$ReplicaAcknowledgementsTableUpdateCompanionBuilder, (ReplicaAcknowledgementRow, BaseReferences<_$SyncDriftDatabase, $ReplicaAcknowledgementsTable, ReplicaAcknowledgementRow>), ReplicaAcknowledgementRow, PrefetchHooks Function()>
$$ReplicaAcknowledgementsTableUpdateCompanionBuilder = ReplicaAcknowledgementsCompanion Function({Value<String> acknowledgedClock, Value<String> entityId, Value<String> entityType, Value<String> nodeId, Value<int> rowid})
$$SyncEntityTableTableCreateCompanionBuilder = SyncEntityTableCompanion Function({Value<int> deleted, required String entityType, required String fieldMetadata, required String id, Value<int> lastModified, required String nodeId, required String payload, Value<int> rowid, required String vectorClock})
$$SyncEntityTableTableProcessedTableManager = ProcessedTableManager<_$SyncDriftDatabase, $SyncEntityTableTable, SyncEntityTableData, $$SyncEntityTableTableFilterComposer, $$SyncEntityTableTableOrderingComposer, $$SyncEntityTableTableAnnotationComposer, $$SyncEntityTableTableCreateCompanionBuilder, $$SyncEntityTableTableUpdateCompanionBuilder, (SyncEntityTableData, BaseReferences<_$SyncDriftDatabase, $SyncEntityTableTable, SyncEntityTableData>), SyncEntityTableData, PrefetchHooks Function()>
$$SyncEntityTableTableUpdateCompanionBuilder = SyncEntityTableCompanion Function({Value<int> deleted, Value<String> entityType, Value<String> fieldMetadata, Value<String> id, Value<int> lastModified, Value<String> nodeId, Value<String> payload, Value<int> rowid, Value<String> vectorClock})