reckon_evoq_checkpoint_store (reckon_evoq v2.0.0)

View Source

Persistent checkpoint store backed by ReckonDB snapshots.

Implements evoq_checkpoint_store using reckon-gater snapshot API. Projection checkpoints survive restarts by storing them as snapshots in a ReckonDB store.

Each projection gets a dedicated snapshot stream named "projection-checkpoint-{module_name}".

Configuration

Set the ReckonDB store to use for checkpoints: application:set_env(reckon_evoq, checkpoint_store_id, my_store).

Default: default_store

Summary

Functions

delete(ProjectionName)

Delete the checkpoint for a projection.

load(ProjectionName)

Load the checkpoint for a projection.

save(ProjectionName, Checkpoint)

Save a checkpoint for a projection.

Functions

delete(ProjectionName)

-spec delete(atom()) -> ok | {error, term()}.

Delete the checkpoint for a projection.

load(ProjectionName)

-spec load(atom()) -> {ok, non_neg_integer()} | {error, not_found | term()}.

Load the checkpoint for a projection.

save(ProjectionName, Checkpoint)

-spec save(atom(), non_neg_integer()) -> ok | {error, term()}.

Save a checkpoint for a projection.