Documentation

withTestMetadata :: (MetadataBeamConnection -> IO a) -> IO a #

migrateDb :: (MonadFail m, MonadIO m) => MetadataBeamConnection -> m () #

migrateUp :: forall be m hdl. (MonadFail m, MetadataDbBackend be, DefaultMigrationBackend be m) => MetadataBeamConnectionContext be hdl m -> m (Maybe (CheckedDatabaseSettings be MetadataDb)) #

newSpecRunId :: MonadIO m => m SpecRunId #

createSpecRunEntry :: (MonadIO m, MonadMetadataDb metaBk m) => UTCTime -> AppName -> Pipeline -> SpecRunId -> SpecTableName -> DepChain -> m SpecRunEntryId #

recordRunFailure :: MonadMetadataDb be m => UTCTime -> SpecRunEntryId -> SomeException -> m () #

recordRunSuccess :: forall b metaBk m. (MonadMetadataDb metaBk m, ToJSON (BackendQueryStats b), Typeable b, ToDbBackend b) => UTCTime -> SpecRunEntryId -> Maybe (CreateQueryStats b) -> Maybe (HookQueryStats b) -> DepChain -> m () #

getSpecRunEntry :: forall be m. MonadMetadataDb be m => SpecRunEntryId -> m (Maybe SpecRun) #

getSpecRunsInfo :: forall be m. MonadMetadataDb be m => AppName -> Integer -> UTCTime -> m [(SpecRunId, UTCTime, Int64)] #

getLatestSpecRun :: forall be m. MonadMetadataDb be m => AppName -> m (Maybe SpecRunId) #

getSpecRun :: forall be m. MonadMetadataDb be m => SpecRunId -> m [SpecRun] #

loadSpecState :: forall be m. MonadMetadataDb be m => AppName -> m [SpecRun] #

loadLastSuccessfulSpecState :: forall be m. MonadMetadataDb be m => AppName -> m [SpecRun] #

loadSpecStateQuery :: forall be s. MetadataDbBackend be => AppName -> Q be MetadataDb s (SpecRunT (QExpr be s)) #

loadLastSuccessfulSpecStateQuery :: forall be s. MetadataDbBackend be => AppName -> Q be MetadataDb s (SpecRunT (QExpr be s)) #

getAverageRuntimeForTables :: forall be m. MonadMetadataDb be m => [SpecTableName] -> m (Map SpecTableName NominalDiffTime) #