Packages

evoq

1.2.1
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_aggregate_lifespan.erl
Raw

src/evoq_aggregate_lifespan.erl 

%% @doc Behavior for controlling aggregate lifecycle.

%%

%% Aggregates can be configured with different lifespan strategies:

%% - TTL-based: Passivate after idle timeout

%% - Hibernate: Reduce memory footprint when idle

%% - Infinite: Keep alive forever (not recommended)

%%

%% The default implementation (evoq_aggregate_lifespan_default) provides

%% sensible defaults with 30-minute TTL and automatic snapshots.

%%

%% @author rgfaber

-module(evoq_aggregate_lifespan).



-include("evoq.hrl").



%% Lifespan action type

-type action() ::

    timeout() |       %% Timeout in milliseconds

    infinity |        %% No timeout

    hibernate |       %% Enter hibernate mode

    stop |            %% Stop immediately

    passivate.        %% Save snapshot and stop



-export_type([action/0]).



%% Required callbacks

-callback after_event(Event :: map()) -> action().

-callback after_command(Command :: map()) -> action().

-callback after_error(Error :: term()) -> action().



%% Optional callbacks

-callback on_timeout(State :: term()) ->

    {ok, action()} | {snapshot, action()}.

-callback on_passivate(State :: term()) ->

    {ok, SnapshotData :: term()} | skip.

-callback on_activate(StreamId :: binary(), Snapshot :: term() | undefined) ->

    {ok, State :: term()}.



-optional_callbacks([on_timeout/1, on_passivate/1, on_activate/2]).