Interface CheckpointStore

Durable checkpoint storage with compare-and-swap writes.

interface CheckpointStore {
    read(id: string): Promise<StoredCheckpoint | null>;
    write(
        checkpoint: FlowCheckpoint,
        expected: number | null,
    ): Promise<boolean>;
}

Implemented by

FileCheckpointStore

Index

Methods

Methods

read

read(id: string): Promise<StoredCheckpoint | null>
Parameters
- id: string
Returns Promise<StoredCheckpoint | null>

write

write(checkpoint: FlowCheckpoint, expected: number | null): Promise<boolean>
Write when the stored revision still equals expected (null: must not exist yet); false on conflict.
Parameters
- checkpoint: FlowCheckpoint
- expected: number | null
Returns Promise<boolean>