Skip to content

checkpoint

django_spire.contrib.sync.django.storage.checkpoint

DjangoCheckpointStore

get_after_keys

Source code in django_spire/contrib/sync/django/storage/checkpoint.py 
10
11
12
13
14
15
16
17
18
19
20
def get_after_keys(self, peer_node_id: str) -> dict[str, Any]:
    checkpoint = (
        SyncCheckpoint.objects
        .filter(peer_node_id=peer_node_id)
        .first()
    )

    if checkpoint is None:
        return {}

    return checkpoint.after_keys or {}

get_checkpoint

Source code in django_spire/contrib/sync/django/storage/checkpoint.py 
22
23
24
25
26
27
28
29
30
31
32
33
34
35
def get_checkpoint(self, peer_node_id: str) -> CheckpointPosition:
    checkpoint = (
        SyncCheckpoint.objects
        .filter(peer_node_id=peer_node_id)
        .first()
    )

    if checkpoint is None:
        return CheckpointPosition(peer_sequence=0, local_sequence_pushed=0)

    return CheckpointPosition(
        peer_sequence=checkpoint.peer_sequence,
        local_sequence_pushed=checkpoint.local_sequence_pushed,
    )

save_checkpoint

Source code in django_spire/contrib/sync/django/storage/checkpoint.py 
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
def save_checkpoint(
    self,
    peer_node_id: str,
    peer_sequence: int,
    local_sequence_pushed: int,
    after_keys: dict[str, Any] | None = None,
) -> None:
    SyncCheckpoint.objects.update_or_create(
        peer_node_id=peer_node_id,
        defaults={
            'after_keys': after_keys or {},
            'local_sequence_pushed': local_sequence_pushed,
            'peer_sequence': peer_sequence,
        },
    )