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