Safe Haskell	Safe-Inferred
Language	Haskell2010

DomainDriven.Persistance.Class

Synopsis

class ReadModel p where
- type Model p :: Type
- type Event p :: Type
- applyEvent :: p -> Model p -> Stored (Event p) -> Model p
- getModel :: p -> IO (Model p)
- getEventList :: p -> IO [Stored (Event p)]
- getEventStream :: p -> SerialT IO (Stored (Event p))
class ReadModel p => WriteModel p where
- transactionalUpdate :: forall m a. MonadUnliftIO m => p -> (Model p -> m (Model p -> a, [Event p])) -> m a
data Stored a = Stored {
- storedEvent :: a
- storedTimestamp :: UTCTime
- storedUUID :: UUID
}
mkId :: MonadIO m => m UUID
toStored :: MonadIO m => e -> m (Stored e)

Documentation

class ReadModel p where Source #

Associated Types

type Model p :: Type Source #

type Event p :: Type Source #

Methods

applyEvent :: p -> Model p -> Stored (Event p) -> Model p Source #

getModel :: p -> IO (Model p) Source #

getEventList :: p -> IO [Stored (Event p)] Source #

getEventStream :: p -> SerialT IO (Stored (Event p)) Source #

Instances

Instances details

ReadModel (ForgetfulInMemory model e) Source #
Instance details Defined in DomainDriven.Persistance.ForgetfulInMemory Associated Types type Model (ForgetfulInMemory model e) Source # type Event (ForgetfulInMemory model e) Source # Methods applyEvent :: ForgetfulInMemory model e -> Model (ForgetfulInMemory model e) -> Stored (Event (ForgetfulInMemory model e)) -> Model (ForgetfulInMemory model e) Source # getModel :: ForgetfulInMemory model e -> IO (Model (ForgetfulInMemory model e)) Source # getEventList :: ForgetfulInMemory model e -> IO [Stored (Event (ForgetfulInMemory model e))] Source # getEventStream :: ForgetfulInMemory model e -> SerialT IO (Stored (Event (ForgetfulInMemory model e))) Source #
FromJSON e => ReadModel (PostgresEvent m e) Source #
Instance details Defined in DomainDriven.Persistance.Postgres.Internal Associated Types type Model (PostgresEvent m e) Source # type Event (PostgresEvent m e) Source # Methods applyEvent :: PostgresEvent m e -> Model (PostgresEvent m e) -> Stored (Event (PostgresEvent m e)) -> Model (PostgresEvent m e) Source # getModel :: PostgresEvent m e -> IO (Model (PostgresEvent m e)) Source # getEventList :: PostgresEvent m e -> IO [Stored (Event (PostgresEvent m e))] Source # getEventStream :: PostgresEvent m e -> SerialT IO (Stored (Event (PostgresEvent m e))) Source #

class ReadModel p => WriteModel p where Source #

Methods

transactionalUpdate :: forall m a. MonadUnliftIO m => p -> (Model p -> m (Model p -> a, [Event p])) -> m a Source #

Instances

Instances details

WriteModel (ForgetfulInMemory model e) Source #
Instance details Defined in DomainDriven.Persistance.ForgetfulInMemory Methods transactionalUpdate :: MonadUnliftIO m => ForgetfulInMemory model e -> (Model (ForgetfulInMemory model e) -> m (Model (ForgetfulInMemory model e) -> a, [Event (ForgetfulInMemory model e)])) -> m a Source #
(ToJSON e, FromJSON e) => WriteModel (PostgresEvent m e) Source #
Instance details Defined in DomainDriven.Persistance.Postgres.Internal Methods transactionalUpdate :: MonadUnliftIO m0 => PostgresEvent m e -> (Model (PostgresEvent m e) -> m0 (Model (PostgresEvent m e) -> a, [Event (PostgresEvent m e)])) -> m0 a Source #

data Stored a Source #

Wrapper for stored data This ensures all events have a unique ID and a timestamp, without having to deal with that when implementing the model.

Constructors

Stored
Fields storedEvent :: a storedTimestamp :: UTCTime storedUUID :: UUID

Instances

Instances details

Foldable Stored Source #
Instance details Defined in DomainDriven.Persistance.Class Methods fold :: Monoid m => Stored m -> m # foldMap :: Monoid m => (a -> m) -> Stored a -> m # foldMap' :: Monoid m => (a -> m) -> Stored a -> m # foldr :: (a -> b -> b) -> b -> Stored a -> b # foldr' :: (a -> b -> b) -> b -> Stored a -> b # foldl :: (b -> a -> b) -> b -> Stored a -> b # foldl' :: (b -> a -> b) -> b -> Stored a -> b # foldr1 :: (a -> a -> a) -> Stored a -> a # foldl1 :: (a -> a -> a) -> Stored a -> a # toList :: Stored a -> [a] # null :: Stored a -> Bool # length :: Stored a -> Int # elem :: Eq a => a -> Stored a -> Bool # maximum :: Ord a => Stored a -> a # minimum :: Ord a => Stored a -> a # sum :: Num a => Stored a -> a # product :: Num a => Stored a -> a #
Traversable Stored Source #
Instance details Defined in DomainDriven.Persistance.Class Methods traverse :: Applicative f => (a -> f b) -> Stored a -> f (Stored b) # sequenceA :: Applicative f => Stored (f a) -> f (Stored a) # mapM :: Monad m => (a -> m b) -> Stored a -> m (Stored b) # sequence :: Monad m => Stored (m a) -> m (Stored a) #
Functor Stored Source #
Instance details Defined in DomainDriven.Persistance.Class Methods fmap :: (a -> b) -> Stored a -> Stored b # (<$) :: a -> Stored b -> Stored a #
FromJSON a => FromJSON (Stored a) Source #
Instance details Defined in DomainDriven.Persistance.Class Methods parseJSON :: Value -> Parser (Stored a) # parseJSONList :: Value -> Parser [Stored a] #
ToJSON a => ToJSON (Stored a) Source #
Instance details Defined in DomainDriven.Persistance.Class Methods toJSON :: Stored a -> Value # toEncoding :: Stored a -> Encoding # toJSONList :: [Stored a] -> Value # toEncodingList :: [Stored a] -> Encoding #
Generic (Stored a) Source #
Instance details Defined in DomainDriven.Persistance.Class Associated Types type Rep (Stored a) :: Type -> Type # Methods from :: Stored a -> Rep (Stored a) x # to :: Rep (Stored a) x -> Stored a #
Show a => Show (Stored a) Source #
Instance details Defined in DomainDriven.Persistance.Class Methods showsPrec :: Int -> Stored a -> ShowS # show :: Stored a -> String # showList :: [Stored a] -> ShowS #
NFData a => NFData (Stored a) Source #
Instance details Defined in DomainDriven.Persistance.Class Methods rnf :: Stored a -> () #
Eq a => Eq (Stored a) Source #
Instance details Defined in DomainDriven.Persistance.Class Methods (==) :: Stored a -> Stored a -> Bool # (/=) :: Stored a -> Stored a -> Bool #
Ord a => Ord (Stored a) Source #
Instance details Defined in DomainDriven.Persistance.Class Methods compare :: Stored a -> Stored a -> Ordering # (<) :: Stored a -> Stored a -> Bool # (<=) :: Stored a -> Stored a -> Bool # (>) :: Stored a -> Stored a -> Bool # (>=) :: Stored a -> Stored a -> Bool # max :: Stored a -> Stored a -> Stored a # min :: Stored a -> Stored a -> Stored a #
type Rep (Stored a) Source #
Instance details Defined in DomainDriven.Persistance.Class type Rep (Stored a) = D1 ('MetaData "Stored" "DomainDriven.Persistance.Class" "domaindriven-core-0.5.0-7rYqBJZZqKF59TNQHBa9rT" 'False) (C1 ('MetaCons "Stored" 'PrefixI 'True) (S1 ('MetaSel ('Just "storedEvent") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 a) :: (S1 ('MetaSel ('Just "storedTimestamp") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :: S1 ('MetaSel ('Just "storedUUID") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UUID))))

mkId :: MonadIO m => m UUID Source #

toStored :: MonadIO m => e -> m (Stored e) Source #