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 'DataConnector -> OnBaseMonad (ExecutionMonad 'DataConnector) (Maybe (AnyBackend ExecutionStats), EncJSON) -> Maybe (PreparedQuery 'DataConnector) -> ResolvedConnectionTemplate 'DataConnector -> 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 'DataConnector -> OnBaseMonad (ExecutionMonad 'DataConnector) EncJSON -> Maybe (PreparedQuery 'DataConnector) -> ResolvedConnectionTemplate 'DataConnector -> m (DiffTime, EncJSON) Source #
runDBSubscription :: (MonadIO m, MonadBaseControl IO m) => SourceConfig 'DataConnector -> MultiplexedQuery 'DataConnector -> [(CohortId, CohortVariables)] -> ResolvedConnectionTemplate 'DataConnector -> m (DiffTime, Either QErr [(CohortId, ByteString)]) Source #
runDBStreamingSubscription :: (MonadIO m, MonadBaseControl IO m) => SourceConfig 'DataConnector -> MultiplexedQuery 'DataConnector -> [(CohortId, CohortVariables)] -> ResolvedConnectionTemplate 'DataConnector -> m (DiffTime, Either QErr [(CohortId, ByteString, CursorVariableValues)]) Source #
runDBQueryExplain :: (MonadIO m, MonadError QErr m, MonadBaseControl IO m, MonadTrace m) => Maybe (CredentialCache AgentLicenseKey) -> DBStepInfo 'DataConnector -> m EncJSON Source #