Safe Haskell	None
Language	Haskell2010

Eventium.Store.Sql.Operations

Synopsis

data SqlEventStoreConfig entity serialized = SqlEventStoreConfig {
- 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 :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> VersionedEventStoreReader (SqlPersistT m) serialized
sqlGlobalEventStoreReader :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> GlobalEventStoreReader (SqlPersistT m) serialized
sqlGetProjectionIds :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> SqlPersistT m [UUID]
sqlGetStreamEvents :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> QueryRange UUID EventVersion -> SqlPersistT m [VersionedStreamEvent serialized]
sqlMaxEventVersion :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> (FieldNameDB -> FieldNameDB -> FieldNameDB -> Text) -> UUID -> SqlPersistT m EventVersion
sqlStoreEvents :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend, SafeToInsert entity) => SqlEventStoreConfig entity serialized -> Maybe (Text -> Text) -> (FieldNameDB -> FieldNameDB -> FieldNameDB -> Text) -> UUID -> [serialized] -> SqlPersistT m EventVersion
unsafeSqlStoreGlobalStreamEvents :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> [GlobalStreamEvent serialized] -> SqlPersistT m ()

Documentation

data SqlEventStoreConfig entity serialized Source #

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 :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> VersionedEventStoreReader (SqlPersistT m) serialized Source #

sqlGlobalEventStoreReader :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> GlobalEventStoreReader (SqlPersistT m) serialized Source #

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

sqlGetStreamEvents :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> QueryRange UUID EventVersion -> SqlPersistT m [VersionedStreamEvent serialized] Source #

sqlMaxEventVersion :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> (FieldNameDB -> FieldNameDB -> FieldNameDB -> Text) -> UUID -> SqlPersistT m EventVersion Source #

sqlStoreEvents :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend, SafeToInsert entity) => SqlEventStoreConfig entity serialized -> Maybe (Text -> Text) -> (FieldNameDB -> FieldNameDB -> FieldNameDB -> Text) -> UUID -> [serialized] -> SqlPersistT m EventVersion Source #

unsafeSqlStoreGlobalStreamEvents :: forall (m :: Type -> Type) entity serialized. (MonadIO m, PersistEntity entity, PersistEntityBackend entity ~ SqlBackend) => SqlEventStoreConfig entity serialized -> [GlobalStreamEvent serialized] -> SqlPersistT m () Source #

Useful if you have some GlobalStreamEvents and you want to shove them in a SQL event store. This can happen when you are moving events between event stores, or you somehow generate the events outside of the current SQL event store.