Packages

evoq

1.4.0
1.23.0 1.22.0 1.21.0 1.20.0 1.19.0 1.15.0 1.14.4 1.14.3 1.14.2 1.14.1 1.14.0 1.13.3 1.13.2 1.13.1 1.13.0 1.12.0 1.11.0 1.10.0 1.9.2 1.9.1 1.9.0 1.8.2 1.8.1 1.8.0 1.7.0 1.6.0 1.5.0 1.4.0 1.3.1 1.3.0 1.2.1 1.2.0 1.1.3 1.1.1 1.1.0 1.0.3 1.0.2 1.0.1 1.0.0

Erlang CQRS/Event Sourcing framework built on reckon-db

HexDocs

Current section

Files

Jump to
Readme
39 Versions
1 Dependency
Dependants
Files
Activity
evoq src evoq_checkpoint_store.erl
Raw

src/evoq_checkpoint_store.erl 

%% @doc Checkpoint store behavior for projections.

%%

%% Provides persistent storage for projection checkpoints.

%% This allows projections to resume from where they left off after restart.

%%

%% == Callbacks ==

%%

%% Required:

%% - load(ProjectionName) -> {ok, Checkpoint} | {error, not_found}

%% - save(ProjectionName, Checkpoint) -> ok | {error, Reason}

%%

%% @author rgfaber

-module(evoq_checkpoint_store).



%% Behavior callbacks

-callback load(ProjectionName :: atom()) ->

    {ok, Checkpoint :: non_neg_integer()} | {error, not_found | term()}.



-callback save(ProjectionName :: atom(), Checkpoint :: non_neg_integer()) ->

    ok | {error, term()}.



%% Optional: delete checkpoint

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



-optional_callbacks([delete/1]).