evoq_checkpoint_store behaviour (evoq v1.14.1)

Checkpoint store behavior for projections.

Provides persistent storage for projection checkpoints. This allows projections to resume from where they left off after restart.

Required: - load(ProjectionName) -> {ok, Checkpoint} | {error, not_found} - save(ProjectionName, Checkpoint) -> ok | {error, Reason}

Summary

delete/1

load/1

save/2

(optional)

-callback delete(ProjectionName :: atom()) -> ok | {error, term()}.

-callback load(ProjectionName :: atom()) ->
                  {ok, Checkpoint :: non_neg_integer()} | {error, not_found | term()}.

-callback save(ProjectionName :: atom(), Checkpoint :: non_neg_integer()) -> ok | {error, term()}.