Packages

eventsourcing

9.1.0
9.1.0 9.0.1 9.0.0 8.0.0 7.0.0 6.2.0 6.1.0 6.0.1 6.0.0 5.0.0 4.0.2 4.0.1 4.0.0 3.0.1 3.0.0 2.0.1 2.0.0 1.0.0 0.2.0 0.1.3 0.1.2 0.1.1 0.1.0

CQRS and Event Soucing in Gleam!

HexDocs

Current section

Files

Jump to
Readme
23 Versions
5 Dependencies
Dependants
Files
Activity
eventsourcing include eventsourcing_EventStore.hrl
Raw

include/eventsourcing_EventStore.hrl 

-record(event_store, {

    execute_transaction :: fun((fun((any()) -> {ok, nil} |

        {error, eventsourcing:event_sourcing_error(any())})) -> {ok, nil} |

        {error, eventsourcing:event_sourcing_error(any())}),

    load_aggregate_transaction :: fun((fun((any()) -> {ok,

            eventsourcing:aggregate(any(), any(), any(), any())} |

        {error, eventsourcing:event_sourcing_error(any())})) -> {ok,

            eventsourcing:aggregate(any(), any(), any(), any())} |

        {error, eventsourcing:event_sourcing_error(any())}),

    load_events_transaction :: fun((fun((any()) -> {ok,

            list(eventsourcing:event_envelop(any()))} |

        {error, eventsourcing:event_sourcing_error(any())})) -> {ok,

            list(eventsourcing:event_envelop(any()))} |

        {error, eventsourcing:event_sourcing_error(any())}),

    get_latest_snapshot_transaction :: fun((fun((any()) -> {ok,

            gleam@option:option(eventsourcing:snapshot(any()))} |

        {error, eventsourcing:event_sourcing_error(any())})) -> {ok,

            gleam@option:option(eventsourcing:snapshot(any()))} |

        {error, eventsourcing:event_sourcing_error(any())}),

    commit_events :: fun((any(), eventsourcing:aggregate(any(), any(), any(), any()), list(any()), list({binary(),

        binary()})) -> {ok,

            {list(eventsourcing:event_envelop(any())), integer()}} |

        {error, eventsourcing:event_sourcing_error(any())}),

    load_events :: fun((any(), any(), binary(), integer()) -> {ok,

            list(eventsourcing:event_envelop(any()))} |

        {error, eventsourcing:event_sourcing_error(any())}),

    load_snapshot :: fun((any(), binary()) -> {ok,

            gleam@option:option(eventsourcing:snapshot(any()))} |

        {error, eventsourcing:event_sourcing_error(any())}),

    save_snapshot :: fun((any(), eventsourcing:snapshot(any())) -> {ok, nil} |

        {error, eventsourcing:event_sourcing_error(any())}),

    eventstore :: any()

}).