Data.CQRS.PostgreSQL

Documentation

newArchiveStore :: IO UUID -> Pool Connection -> IO (ArchiveStore ByteString)

Create an archive store backed by a PostgreSQL connection pool.

newEventStore :: Pool Connection -> IO (EventStore ByteString)

Create an event store backed by a PostgreSQL connection pool. The database which the connections go to must have an appropriate schema as defined by applyMigrations.

newSnapshotStore :: Pool Connection -> IO (SnapshotStore ByteString)

Create an snapshot store backed by a PostgreSQL connection pool.