Data.CQRS.EventStore
Description
Event store functions.
- data EventStore e
- enumerateEventStore :: forall a e. Serialize e => EventStore e -> Int -> Enumerator (PersistedEvent e) IO a
- withEventStore :: IO EventStoreBackend -> (EventStore e -> IO a) -> IO a
Documentation
data EventStore e Source
enumerateEventStore :: forall a e. Serialize e => EventStore e -> Int -> Enumerator (PersistedEvent e) IO aSource
Enumerate all the events from an event store that occur at or later than a given logical timestamp.
withEventStore :: IO EventStoreBackend -> (EventStore e -> IO a) -> IO aSource
Perform an IO action with an open event store.