chronik
chronik copied to clipboard
Chronik
These kind of projections wont need to catchup/replay or to fetch missing events. A possible use case is a price ticker where only the last update is useful.
Aggregates should use the stream functions instead of fetching the whole event log on replay
The current PubSub adapter uses an Elixir Registry to dispatch the domain events. Projections running in a different node should be able to locate the PubSub in a different node...
We could allow the PubSub to publish events on per-aggregate or per-type streams. Alert: in the later the causasality is lost.
This should use a Registry similarly to the one on Aggregates.
Force an aggregate snapshot to persist the last state before shutting down
Check if it possible to let the client application to use its own supervisors to supervise the aggregates. Currently, Chronik provides its own supervisor.