Skip to content

storage

django_spire.contrib.sync.database.storage

CheckpointStore

Bases: Protocol

get_after_keys

Source code in django_spire/contrib/sync/database/storage.py 
10
def get_after_keys(self, node_id: str) -> dict[str, dict[str, int | str]]: ...

get_checkpoint

Source code in django_spire/contrib/sync/database/storage.py 
11
def get_checkpoint(self, node_id: str) -> int: ...

save_checkpoint

Source code in django_spire/contrib/sync/database/storage.py 
12
def save_checkpoint(self, node_id: str, timestamp: int, after_keys: dict[str, dict[str, int | str]] | None = None) -> None: ...

RecordReader

Bases: Protocol

get_changed_since

Source code in django_spire/contrib/sync/database/storage.py 
16
def get_changed_since(self, model_label: str, timestamp: int, limit: int | None = None, after_key: str | None = None) -> dict[str, SyncRecord]: ...

get_deletes_since

Source code in django_spire/contrib/sync/database/storage.py 
17
def get_deletes_since(self, model_label: str, timestamp: int) -> dict[str, int]: ...

get_records

Source code in django_spire/contrib/sync/database/storage.py 
18
def get_records(self, model_label: str, keys: set[str]) -> dict[str, SyncRecord]: ...

RecordWriter

Bases: Protocol

delete_many

Source code in django_spire/contrib/sync/database/storage.py 
22
def delete_many(self, model_label: str, deletes: dict[str, int]) -> None: ...

upsert_many

Source code in django_spire/contrib/sync/database/storage.py 
23
def upsert_many(self, model_label: str, records: dict[str, SyncRecord]) -> set[str]: ...

DatabaseSyncStorage

Bases: CheckpointStore, RecordReader, RecordWriter, Protocol