Eventful.Store.Sql.Operations

Documentation

data SqlEventStoreConfig entity serialized

Constructors

SqlEventStoreConfig

Fields

• sqlEventStoreConfigSequenceMakeEntity :: UUID -> EventVersion -> serialized -> entity
• sqlEventStoreConfigMakeKey :: SequenceNumber -> Key entity
• sqlEventStoreConfigUnKey :: Key entity -> SequenceNumber
• sqlEventStoreConfigUUID :: entity -> UUID
• sqlEventStoreConfigVersion :: entity -> EventVersion
• sqlEventStoreConfigData :: entity -> serialized
• sqlEventStoreConfigSequenceNumberField :: EntityField entity (Key entity)
• sqlEventStoreConfigUUIDField :: EntityField entity UUID
• sqlEventStoreConfigVersionField :: EntityField entity EventVersion
• sqlEventStoreConfigDataField :: EntityField entity serialized

sqlEventStoreReader :: (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> VersionedEventStoreReader (SqlPersistT m) serialized

sqlGlobalEventStoreReader :: (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> GlobalEventStoreReader (SqlPersistT m) serialized

sqlGetProjectionIds :: (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> SqlPersistT m [UUID]

sqlGetAggregateEvents :: (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> QueryRange UUID EventVersion -> SqlPersistT m [VersionedStreamEvent serialized]

sqlMaxEventVersion :: (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> (DBName -> DBName -> DBName -> Text) -> UUID -> SqlPersistT m EventVersion

sqlStoreEvents :: (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> Maybe (Text -> Text) -> (DBName -> DBName -> DBName -> Text) -> UUID -> [serialized] -> SqlPersistT m ()