Safe Haskell	None
Language	Haskell2010

Eventful.Store.Sql

Synopsis

data JSONString
jsonStringSerializer :: (ToJSON a, FromJSON a) => Serializer a JSONString
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 :: (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 ()
type SqlEventId = Key SqlEvent
data SqlEvent = SqlEvent {
- sqlEventUuid :: !UUID
- sqlEventVersion :: !EventVersion
- sqlEventEvent :: !JSONString
}
migrateSqlEvent :: Migration
defaultSqlEventStoreConfig :: SqlEventStoreConfig SqlEvent JSONString

Documentation

data JSONString #

A more specific type than just ByteString for JSON data.

Instances

Eq JSONString #
Instance details Defined in Eventful.Store.Sql.JSONString Methods (==) :: JSONString -> JSONString -> Bool # (/=) :: JSONString -> JSONString -> Bool #
Show JSONString #
Instance details Defined in Eventful.Store.Sql.JSONString Methods showsPrec :: Int -> JSONString -> ShowS # show :: JSONString -> String # showList :: [JSONString] -> ShowS #
PersistFieldSql JSONString #
Instance details Defined in Eventful.Store.Sql.JSONString Methods sqlType :: Proxy JSONString -> SqlType #
PersistField JSONString #
Instance details Defined in Eventful.Store.Sql.JSONString Methods toPersistValue :: JSONString -> PersistValue # fromPersistValue :: PersistValue -> Either Text JSONString #

jsonStringSerializer :: (ToJSON a, FromJSON a) => Serializer a JSONString #

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 () #

type SqlEventId = Key SqlEvent #

data SqlEvent #

Constructors

SqlEvent
Fields sqlEventUuid :: !UUID sqlEventVersion :: !EventVersion sqlEventEvent :: !JSONString

Instances

Show SqlEvent #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods showsPrec :: Int -> SqlEvent -> ShowS # show :: SqlEvent -> String # showList :: [SqlEvent] -> ShowS #
PersistFieldSql SqlEvent #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods sqlType :: Proxy SqlEvent -> SqlType #
PersistEntity SqlEvent #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Associated Types type PersistEntityBackend SqlEvent :: Type # data Key SqlEvent :: Type # data EntityField SqlEvent a :: Type # data Unique SqlEvent :: Type # Methods keyToValues :: Key SqlEvent -> [PersistValue] # keyFromValues :: [PersistValue] -> Either Text (Key SqlEvent) # persistIdField :: EntityField SqlEvent (Key SqlEvent) # entityDef :: Monad m => m SqlEvent -> EntityDef # persistFieldDef :: EntityField SqlEvent typ -> FieldDef # toPersistFields :: SqlEvent -> [SomePersistField] # fromPersistValues :: [PersistValue] -> Either Text SqlEvent # persistUniqueKeys :: SqlEvent -> [Unique SqlEvent] # persistUniqueToFieldNames :: Unique SqlEvent -> [(HaskellName, DBName)] # persistUniqueToValues :: Unique SqlEvent -> [PersistValue] # fieldLens :: EntityField SqlEvent field -> forall (f :: Type -> Type). Functor f => (field -> f field) -> Entity SqlEvent -> f (Entity SqlEvent) #
PersistField SqlEvent #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods toPersistValue :: SqlEvent -> PersistValue # fromPersistValue :: PersistValue -> Either Text SqlEvent #
Eq (Key SqlEvent) #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods (==) :: Key SqlEvent -> Key SqlEvent -> Bool # (/=) :: Key SqlEvent -> Key SqlEvent -> Bool #
Ord (Key SqlEvent) #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods compare :: Key SqlEvent -> Key SqlEvent -> Ordering # (<) :: Key SqlEvent -> Key SqlEvent -> Bool # (<=) :: Key SqlEvent -> Key SqlEvent -> Bool # (>) :: Key SqlEvent -> Key SqlEvent -> Bool # (>=) :: Key SqlEvent -> Key SqlEvent -> Bool # max :: Key SqlEvent -> Key SqlEvent -> Key SqlEvent # min :: Key SqlEvent -> Key SqlEvent -> Key SqlEvent #
Read (Key SqlEvent) #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods readsPrec :: Int -> ReadS (Key SqlEvent) # readList :: ReadS [Key SqlEvent] # readPrec :: ReadPrec (Key SqlEvent) # readListPrec :: ReadPrec [Key SqlEvent] #
Show (Key SqlEvent) #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods showsPrec :: Int -> Key SqlEvent -> ShowS # show :: Key SqlEvent -> String # showList :: [Key SqlEvent] -> ShowS #
ToJSON (Key SqlEvent) #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods toJSON :: Key SqlEvent -> Value # toEncoding :: Key SqlEvent -> Encoding # toJSONList :: [Key SqlEvent] -> Value # toEncodingList :: [Key SqlEvent] -> Encoding #
FromJSON (Key SqlEvent) #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods parseJSON :: Value -> Parser (Key SqlEvent) # parseJSONList :: Value -> Parser [Key SqlEvent] #
ToHttpApiData (Key SqlEvent) #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods toUrlPiece :: Key SqlEvent -> Text # toEncodedUrlPiece :: Key SqlEvent -> Builder # toHeader :: Key SqlEvent -> ByteString # toQueryParam :: Key SqlEvent -> Text #
FromHttpApiData (Key SqlEvent) #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods parseUrlPiece :: Text -> Either Text (Key SqlEvent) # parseHeader :: ByteString -> Either Text (Key SqlEvent) # parseQueryParam :: Text -> Either Text (Key SqlEvent) #
PathPiece (Key SqlEvent) #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods fromPathPiece :: Text -> Maybe (Key SqlEvent) # toPathPiece :: Key SqlEvent -> Text #
PersistFieldSql (Key SqlEvent) #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods sqlType :: Proxy (Key SqlEvent) -> SqlType #
PersistField (Key SqlEvent) #
Instance details Defined in Eventful.Store.Sql.DefaultEntity Methods toPersistValue :: Key SqlEvent -> PersistValue # fromPersistValue :: PersistValue -> Either Text (Key SqlEvent) #
data Unique SqlEvent #
Instance details Defined in Eventful.Store.Sql.DefaultEntity data Unique SqlEvent = UniqueAggregateVersion UUID EventVersion
data EntityField SqlEvent typ #
Instance details Defined in Eventful.Store.Sql.DefaultEntity data EntityField SqlEvent typ where SqlEventId :: forall typ. typ ~ Key SqlEvent => EntityField SqlEvent typ SqlEventUuid :: forall typ. typ ~ UUID => EntityField SqlEvent typ SqlEventVersion :: forall typ. typ ~ EventVersion => EntityField SqlEvent typ SqlEventEvent :: forall typ. typ ~ JSONString => EntityField SqlEvent typ
newtype Key SqlEvent #
Instance details Defined in Eventful.Store.Sql.DefaultEntity newtype Key SqlEvent = SqlEventKey { unSqlEventKey :: SequenceNumber }
type PersistEntityBackend SqlEvent #
Instance details Defined in Eventful.Store.Sql.DefaultEntity type PersistEntityBackend SqlEvent = SqlBackend

migrateSqlEvent :: Migration #

defaultSqlEventStoreConfig :: SqlEventStoreConfig SqlEvent JSONString #