Packages

ex_esdb

0.2.5
0.11.0 0.10.0 0.9.0 0.8.0 0.7.8 0.7.7 0.7.6 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.1 0.6.0 0.5.1 0.5.0 0.4.8 0.4.7 0.4.6 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.3 0.3.2 0.3.1 0.3.0 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.20 0.0.19 0.0.18 0.0.17 0.0.16 0.0.15 0.0.14-alpha 0.0.13-alpha 0.0.12-alpha 0.0.11-alpha 0.0.10-alpha 0.0.9-alpha 0.0.8-alpha 0.0.6-alpha 0.0.5-alpha 0.0.4-alpha 0.0.3-alpha 0.0.2-alfa 0.0.1-alfa

ExESDB is a reincarnation of rabbitmq/khepri, specialized for use as a BEAM-native event store.

HexDocs

Current section

Files

Jump to
Readme
63 Versions
4 Dependencies
Dependants
Files
Activity
ex_esdb src streams.erl
Raw

src/streams.erl 

-module(streams).



-include_lib("khepri/include/khepri.hrl").



-export([setup_when_new_event/3]).



-spec setup_when_new_event(Store :: khepri:store(),

                           Id :: string(),

                           Filter :: khepri:filter()) ->

                            ok | {error, term()}.

setup_when_new_event(Store, Id, Filter) ->

  ok = streams_procs:put_on_new_event(Store, Id),

  ok = streams_triggers:register_on_new_event(Store, Id, Filter),

  ok.