eventsourcing-0.9.0: CQRS/ES library.

Safe HaskellNone
LanguageHaskell2010

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

makeAggregateStore Source #

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