EventStore

CQRS Event Store implemented in Elixir.

Uses PostgreSQL as the underlying storage. Requires version 9.5 or newer.

Sample usage

# start the Storage process
{:ok, store} = EventStore.Storage.start_link

# ensure PostgreSQL tables exist (create if not present) 
EventStore.Storage.initialize_store!(store)

Writing to a Stream

# create a unique identity for the stream (e.g. an aggregate id)
stream_uuid = UUID.uuid4()

# list of events to persist
events = [
  %EventStore.EventData{
    event_type: "ExampleEvent",
    headers: %{user: "someuser@example.com"},
    payload: %ExampleEvent{key: "value"}
  }
]

# append events to the stream
{:ok, events} = EventStore.append_to_stream(store, stream_uuid, 0, events)

Reading Events

{:ok, recorded_events} = EventStore.read_stream_forward(store, uuid, 0)

Installation

If available in Hex, the package can be installed as:

1. Add eventstore to your list of dependencies in mix.exs:

   def deps do

    [{:eventstore, "~> 0.0.1"}]

   end

2. Ensure eventstore is started before your application:

   def application do

    [applications: [:eventstore]]

   end