Safe Haskell | None |
---|---|
Language | Haskell2010 |
Common test functionality
- newtype Counter = Counter {}
- type CounterProjection = Projection Counter CounterEvent
- counterProjection :: CounterProjection
- type CounterAggregate = Aggregate Counter CounterEvent CounterCommand
- counterAggregate :: CounterAggregate
- data CounterEvent
- = Added { }
- | CounterFailedOutOfBounds
- data CounterCommand
- newtype EventStoreRunner m = EventStoreRunner (forall a. (EventStoreWriter m CounterEvent -> VersionedEventStoreReader m CounterEvent -> m a) -> IO a)
- newtype GlobalStreamEventStoreRunner m = GlobalStreamEventStoreRunner (forall a. (EventStoreWriter m CounterEvent -> GlobalEventStoreReader m CounterEvent -> m a) -> IO a)
- eventStoreSpec :: Monad m => EventStoreRunner m -> Spec
- globalStreamEventStoreSpec :: Monad m => GlobalStreamEventStoreRunner m -> Spec
- newtype VersionedProjectionCacheRunner m = VersionedProjectionCacheRunner (forall a. (EventStoreWriter m CounterEvent -> VersionedEventStoreReader m CounterEvent -> VersionedProjectionCache Counter m -> m a) -> IO a)
- versionedProjectionCacheSpec :: Monad m => VersionedProjectionCacheRunner m -> Spec
- newtype GlobalStreamProjectionCacheRunner m = GlobalStreamProjectionCacheRunner (forall a. (EventStoreWriter m CounterEvent -> GlobalEventStoreReader m CounterEvent -> GlobalStreamProjectionCache Text Counter m -> m a) -> IO a)
- globalStreamProjectionCacheSpec :: Monad m => GlobalStreamProjectionCacheRunner m -> Spec
- data Text :: *
Documentation
Example Projection/Aggregate
data CounterEvent Source #
data CounterCommand Source #
newtype EventStoreRunner m Source #
EventStoreRunner (forall a. (EventStoreWriter m CounterEvent -> VersionedEventStoreReader m CounterEvent -> m a) -> IO a) |
newtype GlobalStreamEventStoreRunner m Source #
GlobalStreamEventStoreRunner (forall a. (EventStoreWriter m CounterEvent -> GlobalEventStoreReader m CounterEvent -> m a) -> IO a) |
eventStoreSpec :: Monad m => EventStoreRunner m -> Spec Source #
globalStreamEventStoreSpec :: Monad m => GlobalStreamEventStoreRunner m -> Spec Source #
newtype VersionedProjectionCacheRunner m Source #
VersionedProjectionCacheRunner (forall a. (EventStoreWriter m CounterEvent -> VersionedEventStoreReader m CounterEvent -> VersionedProjectionCache Counter m -> m a) -> IO a) |
newtype GlobalStreamProjectionCacheRunner m Source #
GlobalStreamProjectionCacheRunner (forall a. (EventStoreWriter m CounterEvent -> GlobalEventStoreReader m CounterEvent -> GlobalStreamProjectionCache Text Counter m -> m a) -> IO a) |