Documentation

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

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

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

newSpecRunId :: MonadIO m => m SpecRunId #

createSpecRunEntry :: (MonadIO m, MonadMetadataDb be m) => UTCTime -> AppName -> Pipeline -> SpecRunId -> Ref Table -> DepChain -> m SpecRunEntryId #

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

recordRunSuccess :: MonadMetadataDb be m => UTCTime -> SpecRunEntryId -> Maybe QueryStats -> Maybe QueryStats -> m () #

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

getAll :: forall be m. MonadMetadataDb be m => m [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] #

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

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