Safe Haskell	None
Language	Haskell2010

Database.CQRS.ReadModel.AggregateStore

Documentation

data AggregateStore streamFamily aggregate Source #

Instances

(StreamFamily m streamFamily, Stream m (StreamType streamFamily), MonadError Error m, Hashable (StreamIdentifier streamFamily), MonadIO m, Ord (EventIdentifier (StreamType streamFamily)), Ord (StreamIdentifier streamFamily), Show (EventIdentifier (StreamType streamFamily))) => ReadModel m (AggregateStore streamFamily aggregate) Source #
Instance details Defined in Database.CQRS.ReadModel.AggregateStore Associated Types type ReadModelQuery (AggregateStore streamFamily aggregate) :: Type Source # type ReadModelResponse (AggregateStore streamFamily aggregate) :: Type Source # Methods query :: AggregateStore streamFamily aggregate -> ReadModelQuery (AggregateStore streamFamily aggregate) -> m (ReadModelResponse (AggregateStore streamFamily aggregate)) Source #
type ReadModelQuery (AggregateStore streamFamily aggregate) Source #
Instance details Defined in Database.CQRS.ReadModel.AggregateStore type ReadModelQuery (AggregateStore streamFamily aggregate) = StreamIdentifier streamFamily
type ReadModelResponse (AggregateStore streamFamily aggregate) Source #
Instance details Defined in Database.CQRS.ReadModel.AggregateStore type ReadModelResponse (AggregateStore streamFamily aggregate) = Response (EventIdentifier (StreamType streamFamily)) aggregate

Arguments

:: MonadIO m
=> streamFamily
-> Aggregator (EventWithContext' (StreamType streamFamily)) aggregate
-> (StreamIdentifier streamFamily -> aggregate)
-> NominalDiffTime	Lag tolerance.
-> Int	Maximum number of elements in the cache.
-> m (AggregateStore streamFamily aggregate)

data Response eventId aggregate Source #

Constructors

Response
Fields lastEventId :: Maybe eventId aggregate :: aggregate eventCount :: Int Number of events processed in this fetch. totalEventCount :: Int Total number of events making this aggregate.