Safe Haskell	Safe-Inferred
Language	Haskell2010

DomainDriven.Persistance.Postgres

Synopsis

data EventTable
- = MigrateUsing EventMigration EventTable
- | InitialVersion EventTableBaseName
type EventMigration = PreviousEventTableName -> EventTableName -> Connection -> IO ()
type ChunkSize = Int
type PreviousEventTableName = String
type EventTableName = String
type EventTableBaseName = String
data PostgresEvent model event = PostgresEvent {
- connectionPool :: Pool Connection
- eventTableName :: EventTableName
- modelIORef :: IORef (NumberedModel model)
- app :: model -> Stored event -> model
- seed :: model
- chunkSize :: ChunkSize
}
simplePool' :: MonadUnliftIO m => ConnectInfo -> m (Pool Connection)
simplePool :: MonadUnliftIO m => IO Connection -> m (Pool Connection)
postgresWriteModelNoMigration :: (FromJSON e, WriteModel (PostgresEventTrans m e)) => Pool Connection -> EventTableName -> (m -> Stored e -> m) -> m -> IO (PostgresEvent m e)
postgresWriteModel :: Pool Connection -> EventTable -> (m -> Stored e -> m) -> m -> IO (PostgresEvent m e)

Documentation

data EventTable Source #

Constructors

MigrateUsing EventMigration EventTable
InitialVersion EventTableBaseName

type EventMigration = PreviousEventTableName -> EventTableName -> Connection -> IO () Source #

type ChunkSize = Int Source #

type PreviousEventTableName = String Source #

type EventTableName = String Source #

type EventTableBaseName = String Source #

data PostgresEvent model event Source #

Constructors

PostgresEvent
Fields connectionPool :: Pool Connection eventTableName :: EventTableName modelIORef :: IORef (NumberedModel model) app :: model -> Stored event -> model seed :: model chunkSize :: ChunkSize Number of events read from postgres per batch

Instances

Instances details

Generic (PostgresEvent model event) Source #
Instance details Defined in DomainDriven.Persistance.Postgres.Internal Associated Types type Rep (PostgresEvent model event) :: Type -> Type # Methods from :: PostgresEvent model event -> Rep (PostgresEvent model event) x # to :: Rep (PostgresEvent model event) x -> PostgresEvent model event #
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 #
(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 #
type Rep (PostgresEvent model event) Source #
Instance details Defined in DomainDriven.Persistance.Postgres.Internal type Rep (PostgresEvent model event) = D1 ('MetaData "PostgresEvent" "DomainDriven.Persistance.Postgres.Internal" "domaindriven-core-0.5.0-7rYqBJZZqKF59TNQHBa9rT" 'False) (C1 ('MetaCons "PostgresEvent" 'PrefixI 'True) ((S1 ('MetaSel ('Just "connectionPool") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Pool Connection)) :: (S1 ('MetaSel ('Just "eventTableName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 EventTableName) :: S1 ('MetaSel ('Just "modelIORef") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (IORef (NumberedModel model))))) :: (S1 ('MetaSel ('Just "app") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (model -> Stored event -> model)) :: (S1 ('MetaSel ('Just "seed") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 model) :*: S1 ('MetaSel ('Just "chunkSize") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChunkSize)))))
type Event (PostgresEvent m e) Source #
Instance details Defined in DomainDriven.Persistance.Postgres.Internal type Event (PostgresEvent m e) = e
type Model (PostgresEvent m e) Source #
Instance details Defined in DomainDriven.Persistance.Postgres.Internal type Model (PostgresEvent m e) = m

simplePool' :: MonadUnliftIO m => ConnectInfo -> m (Pool Connection) Source #

simplePool :: MonadUnliftIO m => IO Connection -> m (Pool Connection) Source #

postgresWriteModelNoMigration :: (FromJSON e, WriteModel (PostgresEventTrans m e)) => Pool Connection -> EventTableName -> (m -> Stored e -> m) -> m -> IO (PostgresEvent m e) Source #

Setup the persistance model and verify that the tables exist.

postgresWriteModel :: Pool Connection -> EventTable -> (m -> Stored e -> m) -> m -> IO (PostgresEvent m e) Source #

Setup the persistance model and verify that the tables exist.