Raxol.Architecture.EventSourcing.EventStore (Raxol v2.0.1)
View SourceEvent store implementation for event sourcing pattern.
Provides functionality to store, retrieve, and subscribe to events in a functional programming style.
Summary
Functions
Append a single event to a stream.
Append multiple events to a stream.
Append multiple events to a stream (with server name as first argument).
Returns a specification to start this module under a supervisor.
Delete a stream (soft delete).
Get event store statistics.
Get stream information.
Read all events across all streams.
Read events from a stream.
Starts the event store.
Subscribe to events from a stream or all events.
Unsubscribe from events.
Types
@type event() :: %{ id: binary(), stream_name: binary(), event_type: binary(), data: map(), metadata: map(), timestamp: DateTime.t(), version: non_neg_integer() }
@type event_id() :: binary()
@type stream_name() :: binary()
@type version() :: non_neg_integer()
Functions
Append a single event to a stream.
Append multiple events to a stream.
Append multiple events to a stream (with server name as first argument).
Returns a specification to start this module under a supervisor.
See Supervisor.
Delete a stream (soft delete).
Get event store statistics.
Get stream information.
Read all events across all streams.
Read events from a stream.
Starts the event store.
Subscribe to events from a stream or all events.
Unsubscribe from events.