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. (EventStore CounterEvent m -> m a) -> IO a)
- newtype GloballyOrderedEventStoreRunner m = GloballyOrderedEventStoreRunner (forall a. (EventStore CounterEvent m -> GloballyOrderedEventStore CounterEvent m -> m a) -> IO a)
- eventStoreSpec :: Monad m => EventStoreRunner m -> Spec
- sequencedEventStoreSpec :: Monad m => GloballyOrderedEventStoreRunner m -> Spec
- newtype StreamProjectionCacheRunner m = StreamProjectionCacheRunner (forall a. (EventStore CounterEvent m -> StreamProjectionCache Counter m -> m a) -> IO a)
- streamProjectionCacheSpec :: Monad m => StreamProjectionCacheRunner m -> Spec
- newtype GloballyOrderedProjectionCacheRunner m = GloballyOrderedProjectionCacheRunner (forall a. (EventStore CounterEvent m -> GloballyOrderedEventStore CounterEvent m -> GloballyOrderedProjectionCache Text Counter m -> m a) -> IO a)
- globallyOrderedProjectionCacheSpec :: Monad m => GloballyOrderedProjectionCacheRunner m -> Spec
- data Text :: *
Documentation
Example Projection/Aggregate
data CounterEvent Source #
data CounterCommand Source #
newtype EventStoreRunner m Source #
EventStoreRunner (forall a. (EventStore CounterEvent m -> m a) -> IO a) |
newtype GloballyOrderedEventStoreRunner m Source #
GloballyOrderedEventStoreRunner (forall a. (EventStore CounterEvent m -> GloballyOrderedEventStore CounterEvent m -> m a) -> IO a) |
eventStoreSpec :: Monad m => EventStoreRunner m -> Spec Source #
sequencedEventStoreSpec :: Monad m => GloballyOrderedEventStoreRunner m -> Spec Source #
newtype StreamProjectionCacheRunner m Source #
StreamProjectionCacheRunner (forall a. (EventStore CounterEvent m -> StreamProjectionCache Counter m -> m a) -> IO a) |
streamProjectionCacheSpec :: Monad m => StreamProjectionCacheRunner m -> Spec Source #
newtype GloballyOrderedProjectionCacheRunner m Source #
GloballyOrderedProjectionCacheRunner (forall a. (EventStore CounterEvent m -> GloballyOrderedEventStore CounterEvent m -> GloballyOrderedProjectionCache Text Counter m -> m a) -> IO a) |