Methods
runDBQuery :: (MonadIO m, MonadBaseControl IO m, MonadError QErr m, MonadQueryLog m, MonadExecutionLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> Maybe (CredentialCache AgentLicenseKey) -> SourceConfig ('Postgres pgKind) -> OnBaseMonad (ExecutionMonad ('Postgres pgKind)) (Maybe (AnyBackend ExecutionStats), EncJSON) -> Maybe (PreparedQuery ('Postgres pgKind)) -> ResolvedConnectionTemplate ('Postgres pgKind) -> m (DiffTime, EncJSON) Source #
runDBMutation :: (MonadIO m, MonadBaseControl IO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> Maybe (CredentialCache AgentLicenseKey) -> SourceConfig ('Postgres pgKind) -> OnBaseMonad (ExecutionMonad ('Postgres pgKind)) EncJSON -> Maybe (PreparedQuery ('Postgres pgKind)) -> ResolvedConnectionTemplate ('Postgres pgKind) -> m (DiffTime, EncJSON) Source #
runDBSubscription :: (MonadIO m, MonadBaseControl IO m) => SourceConfig ('Postgres pgKind) -> MultiplexedQuery ('Postgres pgKind) -> [(CohortId, CohortVariables)] -> ResolvedConnectionTemplate ('Postgres pgKind) -> m (DiffTime, Either QErr [(CohortId, ByteString)]) Source #
runDBStreamingSubscription :: (MonadIO m, MonadBaseControl IO m) => SourceConfig ('Postgres pgKind) -> MultiplexedQuery ('Postgres pgKind) -> [(CohortId, CohortVariables)] -> ResolvedConnectionTemplate ('Postgres pgKind) -> m (DiffTime, Either QErr [(CohortId, ByteString, CursorVariableValues)]) Source #
runDBQueryExplain :: (MonadIO m, MonadError QErr m, MonadBaseControl IO m, MonadTrace m) => Maybe (CredentialCache AgentLicenseKey) -> DBStepInfo ('Postgres pgKind) -> m EncJSON Source #