Safe Haskell	None
Language	Haskell2010

Hasura.GraphQL.Transport.Backend

Synopsis

class BackendExecute b => BackendTransport (b :: BackendType) where
- runDBQuery :: forall m. (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig b -> ExecutionMonad b EncJSON -> Maybe (PreparedQuery b) -> m (DiffTime, EncJSON)
- runDBMutation :: forall m. (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig b -> ExecutionMonad b EncJSON -> Maybe (PreparedQuery b) -> m (DiffTime, EncJSON)
- runDBSubscription :: forall m. MonadIO m => SourceConfig b -> MultiplexedQuery b -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString)])
- runDBStreamingSubscription :: forall m. MonadIO m => SourceConfig b -> MultiplexedQuery b -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString, CursorVariableValues)])
- runDBQueryExplain :: forall m. (MonadIO m, MonadError QErr m) => DBStepInfo b -> m EncJSON

Documentation

class BackendExecute b => BackendTransport (b :: BackendType) where Source #

This typeclass enacapsulates how a given backend sends queries and mutations over the network. Each backend is currently responsible for both logging and tracing, for now.

Methods

runDBQuery :: forall m. (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig b -> ExecutionMonad b EncJSON -> Maybe (PreparedQuery b) -> m (DiffTime, EncJSON) Source #

runDBMutation :: forall m. (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig b -> ExecutionMonad b EncJSON -> Maybe (PreparedQuery b) -> m (DiffTime, EncJSON) Source #

runDBSubscription Source #

Arguments

:: forall m. MonadIO m
=> SourceConfig b
-> MultiplexedQuery b
-> [(CohortId, CohortVariables)]	WARNING: Postgres-specific, ignored by other backends
-> m (DiffTime, Either QErr [(CohortId, ByteString)])

runDBStreamingSubscription Source #

Arguments

:: forall m. MonadIO m
=> SourceConfig b
-> MultiplexedQuery b
-> [(CohortId, CohortVariables)]	WARNING: Postgres-specific, ignored by other backends
-> m (DiffTime, Either QErr [(CohortId, ByteString, CursorVariableValues)])

runDBQueryExplain :: forall m. (MonadIO m, MonadError QErr m) => DBStepInfo b -> m EncJSON Source #

Instances

Instances details

BackendTransport 'MSSQL Source #
Instance details Defined in Hasura.Backends.MSSQL.Instances.Transport Methods runDBQuery :: (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig 'MSSQL -> ExecutionMonad 'MSSQL EncJSON -> Maybe (PreparedQuery 'MSSQL) -> m (DiffTime, EncJSON) Source # runDBMutation :: (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig 'MSSQL -> ExecutionMonad 'MSSQL EncJSON -> Maybe (PreparedQuery 'MSSQL) -> m (DiffTime, EncJSON) Source # runDBSubscription :: MonadIO m => SourceConfig 'MSSQL -> MultiplexedQuery 'MSSQL -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString)]) Source # runDBStreamingSubscription :: MonadIO m => SourceConfig 'MSSQL -> MultiplexedQuery 'MSSQL -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString, CursorVariableValues)]) Source # runDBQueryExplain :: (MonadIO m, MonadError QErr m) => DBStepInfo 'MSSQL -> m EncJSON Source #
BackendTransport 'BigQuery Source #
Instance details Defined in Hasura.Backends.BigQuery.Instances.Transport Methods runDBQuery :: (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig 'BigQuery -> ExecutionMonad 'BigQuery EncJSON -> Maybe (PreparedQuery 'BigQuery) -> m (DiffTime, EncJSON) Source # runDBMutation :: (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig 'BigQuery -> ExecutionMonad 'BigQuery EncJSON -> Maybe (PreparedQuery 'BigQuery) -> m (DiffTime, EncJSON) Source # runDBSubscription :: MonadIO m => SourceConfig 'BigQuery -> MultiplexedQuery 'BigQuery -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString)]) Source # runDBStreamingSubscription :: MonadIO m => SourceConfig 'BigQuery -> MultiplexedQuery 'BigQuery -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString, CursorVariableValues)]) Source # runDBQueryExplain :: (MonadIO m, MonadError QErr m) => DBStepInfo 'BigQuery -> m EncJSON Source #
BackendTransport 'MySQL Source #
Instance details Defined in Hasura.Backends.MySQL.Instances.Transport Methods runDBQuery :: (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig 'MySQL -> ExecutionMonad 'MySQL EncJSON -> Maybe (PreparedQuery 'MySQL) -> m (DiffTime, EncJSON) Source # runDBMutation :: (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig 'MySQL -> ExecutionMonad 'MySQL EncJSON -> Maybe (PreparedQuery 'MySQL) -> m (DiffTime, EncJSON) Source # runDBSubscription :: MonadIO m => SourceConfig 'MySQL -> MultiplexedQuery 'MySQL -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString)]) Source # runDBStreamingSubscription :: MonadIO m => SourceConfig 'MySQL -> MultiplexedQuery 'MySQL -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString, CursorVariableValues)]) Source # runDBQueryExplain :: (MonadIO m, MonadError QErr m) => DBStepInfo 'MySQL -> m EncJSON Source #
BackendTransport 'DataConnector Source #
Instance details Defined in Hasura.Backends.DataConnector.Adapter.Transport Methods runDBQuery :: (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig 'DataConnector -> ExecutionMonad 'DataConnector EncJSON -> Maybe (PreparedQuery 'DataConnector) -> m (DiffTime, EncJSON) Source # runDBMutation :: (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig 'DataConnector -> ExecutionMonad 'DataConnector EncJSON -> Maybe (PreparedQuery 'DataConnector) -> m (DiffTime, EncJSON) Source # runDBSubscription :: MonadIO m => SourceConfig 'DataConnector -> MultiplexedQuery 'DataConnector -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString)]) Source # runDBStreamingSubscription :: MonadIO m => SourceConfig 'DataConnector -> MultiplexedQuery 'DataConnector -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString, CursorVariableValues)]) Source # runDBQueryExplain :: (MonadIO m, MonadError QErr m) => DBStepInfo 'DataConnector -> m EncJSON Source #
(Backend ('Postgres pgKind), PostgresAnnotatedFieldJSON pgKind) => BackendTransport ('Postgres pgKind) Source #
Instance details Defined in Hasura.Backends.Postgres.Instances.Transport Methods runDBQuery :: (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig ('Postgres pgKind) -> ExecutionMonad ('Postgres pgKind) EncJSON -> Maybe (PreparedQuery ('Postgres pgKind)) -> m (DiffTime, EncJSON) Source # runDBMutation :: (MonadIO m, MonadError QErr m, MonadQueryLog m, MonadTrace m) => RequestId -> GQLReqUnparsed -> RootFieldAlias -> UserInfo -> Logger Hasura -> SourceConfig ('Postgres pgKind) -> ExecutionMonad ('Postgres pgKind) EncJSON -> Maybe (PreparedQuery ('Postgres pgKind)) -> m (DiffTime, EncJSON) Source # runDBSubscription :: MonadIO m => SourceConfig ('Postgres pgKind) -> MultiplexedQuery ('Postgres pgKind) -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString)]) Source # runDBStreamingSubscription :: MonadIO m => SourceConfig ('Postgres pgKind) -> MultiplexedQuery ('Postgres pgKind) -> [(CohortId, CohortVariables)] -> m (DiffTime, Either QErr [(CohortId, ByteString, CursorVariableValues)]) Source # runDBQueryExplain :: (MonadIO m, MonadError QErr m) => DBStepInfo ('Postgres pgKind) -> m EncJSON Source #