Safe Haskell	Safe-Inferred
Language	Haskell2010

Hasura.GraphQL.Execute.Subscription.Poll.Common

Description

Multiplexed subscription poller threads; see Hasura.GraphQL.Execute.Subscription for details.

Synopsis

data SubscriberId
newSubscriberId :: IO SubscriberId
data SubscriberMetadata
mkSubscriberMetadata :: WSId -> OperationId -> Maybe OperationName -> RequestId -> SubscriberMetadata
data Subscriber = Subscriber {
- _sId :: !SubscriberId
- _sMetadata :: !SubscriberMetadata
- _sRequestId :: !RequestId
- _sOperationName :: !(Maybe OperationName)
- _sOnChangeCallback :: !OnChange
}
data SubscriptionMetadata = SubscriptionMetadata {
- _sqmExecutionTime :: !DiffTime
}
data SubscriptionResponse = SubscriptionResponse {
- _lqrPayload :: !ByteString
- _lqrExecutionTime :: !DiffTime
}
type SubscriptionGQResponse = GQResult SubscriptionResponse
type OnChange = SubscriptionGQResponse -> IO ()
type SubscriberMap = TMap SubscriberId Subscriber
data PollerResponseState
- = PRSSuccess
- | PRSError
data Cohort streamCursorVars = Cohort {
- _cCohortId :: CohortId
- _cPreviousResponse :: TVar (Maybe ResponseHash)
- _cExistingSubscribers :: SubscriberMap
- _cNewSubscribers :: SubscriberMap
- _cStreamCursorVariables :: streamCursorVars
}
newtype BatchId = BatchId {
- _unBatchId :: Int
}
newtype ResponseHash = ResponseHash {
- unResponseHash :: Digest Blake2b_256
}
mkRespHash :: ByteString -> ResponseHash
type CohortKey = CohortVariables
type CohortMap streamCursor = TMap CohortKey (Cohort streamCursor)
data CohortSnapshot = CohortSnapshot {
- _csVariables :: CohortVariables
- _csPreviousResponse :: TVar (Maybe ResponseHash)
- _csExistingSubscribers :: [Subscriber]
- _csNewSubscribers :: [Subscriber]
}
data Poller streamCursor = Poller {
- _pCohorts :: CohortMap streamCursor
- _pPollerState :: TVar PollerResponseState
- _pIOState :: TMVar PollerIOState
- _pParameterizedQueryHash :: ParameterizedQueryHash
- _pOperationNamesMap :: TMap (Maybe OperationName) Int
}
data PollerIOState = PollerIOState {
- _pThread :: !Thread
- _pId :: !PollerId
}
data PollerKey b = PollerKey {
- _lgSource :: SourceName
- _lgRole :: RoleName
- _lgQuery :: Text
- _lgConnectionKey :: ResolvedConnectionTemplate b
- _lgParameterizedQueryHash :: ParameterizedQueryHash
}
newtype BackendPollerKey = BackendPollerKey {
- unBackendPollerKey :: AnyBackend PollerKey
}
type PollerMap streamCursor = Map BackendPollerKey (Poller streamCursor)
dumpPollerMap :: Bool -> PollerMap streamCursor -> IO Value
newtype PollerId = PollerId {
- unPollerId :: UUID
}
data SubscriberExecutionDetails = SubscriberExecutionDetails {
- _sedSubscriberId :: !SubscriberId
- _sedSubscriberMetadata :: !SubscriberMetadata
}
data CohortExecutionDetails = CohortExecutionDetails {
- _cedCohortId :: !CohortId
- _cedVariables :: !CohortVariables
- _cedResponseSize :: !(Maybe Int)
- _cedPushedTo :: ![SubscriberExecutionDetails]
- _cedIgnored :: ![SubscriberExecutionDetails]
- _cedBatchId :: !BatchId
}
data BatchExecutionDetails = BatchExecutionDetails {
- _bedPgExecutionTime :: Maybe DiffTime
- _bedDbExecutionTime :: DiffTime
- _bedPushTime :: DiffTime
- _bedBatchId :: BatchId
- _bedCohorts :: [CohortExecutionDetails]
- _bedBatchResponseSizeBytes :: Maybe Int
}
data PollDetailsError = PollDetailsError {
- _pdeBatchId :: BatchId
- _pdeErrorDetails :: QErr
}
data PollDetails = PollDetails {
- _pdPollerId :: PollerId
- _pdKind :: SubscriptionType
- _pdGeneratedSql :: Text
- _pdSnapshotTime :: DiffTime
- _pdBatches :: [BatchExecutionDetails]
- _pdTotalTime :: DiffTime
- _pdLiveQueryOptions :: SubscriptionsOptions
- _pdSource :: SourceName
- _pdRole :: RoleName
- _pdParameterizedQueryHash :: ParameterizedQueryHash
- _pdLogLevel :: LogLevel
- _pdErrors :: Maybe [PollDetailsError]
}
type SubscriptionPostPollHook = PollDetails -> IO ()
defaultSubscriptionPostPollHook :: Logger Hasura -> SubscriptionPostPollHook

Documentation

data SubscriberId Source #

Instances

Instances details

ToJSON SubscriberId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods toJSON :: SubscriberId -> Value Source # toEncoding :: SubscriberId -> Encoding Source # toJSONList :: [SubscriberId] -> Value Source # toEncodingList :: [SubscriberId] -> Encoding Source #
Generic SubscriberId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Associated Types type Rep SubscriberId :: Type -> Type # Methods from :: SubscriberId -> Rep SubscriberId x # to :: Rep SubscriberId x -> SubscriberId #
Show SubscriberId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> SubscriberId -> ShowS # show :: SubscriberId -> String # showList :: [SubscriberId] -> ShowS #
Eq SubscriberId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: SubscriberId -> SubscriberId -> Bool # (/=) :: SubscriberId -> SubscriberId -> Bool #
Hashable SubscriberId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods hashWithSalt :: Int -> SubscriberId -> Int Source # hash :: SubscriberId -> Int Source #
type Rep SubscriberId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common type Rep SubscriberId = D1 ('MetaData "SubscriberId" "Hasura.GraphQL.Execute.Subscription.Poll.Common" "graphql-engine-1.0.0-inplace" 'True) (C1 ('MetaCons "SubscriberId" 'PrefixI 'True) (S1 ('MetaSel ('Just "unSubscriberId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UUID)))

newSubscriberId :: IO SubscriberId Source #

data SubscriberMetadata Source #

Allows a user of the live query subsystem (currently websocket transport) to attach arbitrary metadata about a subscriber. This information is available as part of Subscriber in CohortExecutionDetails and can be logged by customizing in pollerlog

Instances

Instances details

ToJSON SubscriberMetadata Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods toJSON :: SubscriberMetadata -> Value Source # toEncoding :: SubscriberMetadata -> Encoding Source # toJSONList :: [SubscriberMetadata] -> Value Source # toEncodingList :: [SubscriberMetadata] -> Encoding Source #
Show SubscriberMetadata Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> SubscriberMetadata -> ShowS # show :: SubscriberMetadata -> String # showList :: [SubscriberMetadata] -> ShowS #
Eq SubscriberMetadata Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: SubscriberMetadata -> SubscriberMetadata -> Bool # (/=) :: SubscriberMetadata -> SubscriberMetadata -> Bool #

mkSubscriberMetadata :: WSId -> OperationId -> Maybe OperationName -> RequestId -> SubscriberMetadata Source #

data Subscriber Source #

Constructors

Subscriber
Fields _sId :: !SubscriberId _sMetadata :: !SubscriberMetadata _sRequestId :: !RequestId _sOperationName :: !(Maybe OperationName) _sOnChangeCallback :: !OnChange

data SubscriptionMetadata Source #

Subscription onChange metadata, used for adding more extra analytics data

Constructors

SubscriptionMetadata
Fields _sqmExecutionTime :: !DiffTime

data SubscriptionResponse Source #

Constructors

SubscriptionResponse
Fields _lqrPayload :: !ByteString _lqrExecutionTime :: !DiffTime

type SubscriptionGQResponse = GQResult SubscriptionResponse Source #

type OnChange = SubscriptionGQResponse -> IO () Source #

type SubscriberMap = TMap SubscriberId Subscriber Source #

data PollerResponseState Source #

Constructors

PRSSuccess
PRSError

Instances

Instances details

Eq PollerResponseState Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: PollerResponseState -> PollerResponseState -> Bool # (/=) :: PollerResponseState -> PollerResponseState -> Bool #

data Cohort streamCursorVars Source #

A batched group of Subscribers who are not only listening to the same query but also have identical session and query variables. Each result pushed to a Cohort is forwarded along to each of its Subscribers.

In SQL, each Cohort corresponds to a single row in the laterally-joined _subs table (and therefore a single row in the query result).

Instances

Instances details

ToJSON BatchId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods toJSON :: BatchId -> Value Source # toEncoding :: BatchId -> Encoding Source # toJSONList :: [BatchId] -> Value Source # toEncodingList :: [BatchId] -> Encoding Source #
Show BatchId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> BatchId -> ShowS # show :: BatchId -> String # showList :: [BatchId] -> ShowS #
Eq BatchId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: BatchId -> BatchId -> Bool # (/=) :: BatchId -> BatchId -> Bool #

newtype ResponseHash Source #

A hash used to determine if the result changed without having to keep the entire result in memory. Using a cryptographic hash ensures that a hash collision is almost impossible: with 256 bits, even if a subscription changes once per second for an entire year, the probability of a hash collision is ~4.294417×10-63. See Note [Blake2b faster than SHA-256].

Constructors

ResponseHash
Fields unResponseHash :: Digest Blake2b_256

Instances

Instances details

ToJSON ResponseHash Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods toJSON :: ResponseHash -> Value Source # toEncoding :: ResponseHash -> Encoding Source # toJSONList :: [ResponseHash] -> Value Source # toEncodingList :: [ResponseHash] -> Encoding Source #
Show ResponseHash Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> ResponseHash -> ShowS # show :: ResponseHash -> String # showList :: [ResponseHash] -> ShowS #
Eq ResponseHash Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: ResponseHash -> ResponseHash -> Bool # (/=) :: ResponseHash -> ResponseHash -> Bool #

mkRespHash :: ByteString -> ResponseHash Source #

type CohortKey = CohortVariables Source #

A key we use to determine if two Subscribers belong in the same Cohort (assuming they already meet the criteria to be in the same Poller). Note the distinction between this and CohortId; the latter is a completely synthetic key used only to identify the cohort in the generated SQL query.

type CohortMap streamCursor = TMap CohortKey (Cohort streamCursor) Source #

This has the invariant, maintained in removeLiveQuery, that it contains no Cohort with zero total (existing + new) subscribers.

data CohortSnapshot Source #

Constructors

CohortSnapshot
Fields _csVariables :: CohortVariables _csPreviousResponse :: TVar (Maybe ResponseHash) _csExistingSubscribers :: [Subscriber] _csNewSubscribers :: [Subscriber]

data Poller streamCursor Source #

A unique, multiplexed query. Each Poller has its own polling thread that periodically polls Postgres and pushes results to each of its listening Cohorts.

In SQL, an Poller corresponds to a single, multiplexed query, though in practice, Pollers with large numbers of Cohorts are batched into multiple concurrent queries for performance reasons.

Constructors

Poller

Fields

_pCohorts :: CohortMap streamCursor
_pPollerState :: TVar PollerResponseState
_pIOState :: TMVar PollerIOState
This is in a separate TMVar because it’s important that we are able to construct Poller values in STM --- we need the insertion into the PollerMap to be atomic to ensure that we don’t accidentally create two for the same query due to a race. However, we can’t spawn the worker thread or create the metrics store in STM, so we insert it into the Poller only after we’re certain we won’t create any duplicates.
This var is "write once", moving monotonically from empty to full. TODO this could probably be tightened up to something like 'STM PollerIOState'
_pParameterizedQueryHash :: ParameterizedQueryHash
_pOperationNamesMap :: TMap (Maybe OperationName) Int

data PollerIOState Source #

Constructors

PollerIOState
Fields _pThread :: !Thread a handle on the poller’s worker thread that can be used to `stop` it if all its cohorts stop listening _pId :: !PollerId

data PollerKey b Source #

Constructors

PollerKey
Fields _lgSource :: SourceName _lgRole :: RoleName _lgQuery :: Text _lgConnectionKey :: ResolvedConnectionTemplate b _lgParameterizedQueryHash :: ParameterizedQueryHash

Instances

Instances details

ToJSON (PollerKey b) Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods toJSON :: PollerKey b -> Value Source # toEncoding :: PollerKey b -> Encoding Source # toJSONList :: [PollerKey b] -> Value Source # toEncodingList :: [PollerKey b] -> Encoding Source #
Generic (PollerKey b) Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Associated Types type Rep (PollerKey b) :: Type -> Type # Methods from :: PollerKey b -> Rep (PollerKey b) x # to :: Rep (PollerKey b) x -> PollerKey b #
Backend b => Show (PollerKey b) Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> PollerKey b -> ShowS # show :: PollerKey b -> String # showList :: [PollerKey b] -> ShowS #
Backend b => Eq (PollerKey b) Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: PollerKey b -> PollerKey b -> Bool # (/=) :: PollerKey b -> PollerKey b -> Bool #
Backend b => Hashable (PollerKey b) Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods hashWithSalt :: Int -> PollerKey b -> Int Source # hash :: PollerKey b -> Int Source #
type Rep (PollerKey b) Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common type Rep (PollerKey b) = D1 ('MetaData "PollerKey" "Hasura.GraphQL.Execute.Subscription.Poll.Common" "graphql-engine-1.0.0-inplace" 'False) (C1 ('MetaCons "PollerKey" 'PrefixI 'True) ((S1 ('MetaSel ('Just "_lgSource") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 SourceName) :: S1 ('MetaSel ('Just "_lgRole") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 RoleName)) :: (S1 ('MetaSel ('Just "_lgQuery") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 Text) :: (S1 ('MetaSel ('Just "_lgConnectionKey") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (ResolvedConnectionTemplate b)) :: S1 ('MetaSel ('Just "_lgParameterizedQueryHash") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 ParameterizedQueryHash)))))

newtype BackendPollerKey Source #

Constructors

BackendPollerKey
Fields unBackendPollerKey :: AnyBackend PollerKey

Instances

Instances details

Show BackendPollerKey Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> BackendPollerKey -> ShowS # show :: BackendPollerKey -> String # showList :: [BackendPollerKey] -> ShowS #
Eq BackendPollerKey Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: BackendPollerKey -> BackendPollerKey -> Bool # (/=) :: BackendPollerKey -> BackendPollerKey -> Bool #
Hashable BackendPollerKey Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods hashWithSalt :: Int -> BackendPollerKey -> Int Source # hash :: BackendPollerKey -> Int Source #

type PollerMap streamCursor = Map BackendPollerKey (Poller streamCursor) Source #

dumpPollerMap :: Bool -> PollerMap streamCursor -> IO Value Source #

For dev debugging, output subject to change.

newtype PollerId Source #

An ID to track unique Pollers, so that we can gather metrics about each poller

Constructors

PollerId
Fields unPollerId :: UUID

Instances

Instances details

ToJSON PollerId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods toJSON :: PollerId -> Value Source # toEncoding :: PollerId -> Encoding Source # toJSONList :: [PollerId] -> Value Source # toEncodingList :: [PollerId] -> Encoding Source #
Generic PollerId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Associated Types type Rep PollerId :: Type -> Type # Methods from :: PollerId -> Rep PollerId x # to :: Rep PollerId x -> PollerId #
Show PollerId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> PollerId -> ShowS # show :: PollerId -> String # showList :: [PollerId] -> ShowS #
Eq PollerId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: PollerId -> PollerId -> Bool # (/=) :: PollerId -> PollerId -> Bool #
type Rep PollerId Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common type Rep PollerId = D1 ('MetaData "PollerId" "Hasura.GraphQL.Execute.Subscription.Poll.Common" "graphql-engine-1.0.0-inplace" 'True) (C1 ('MetaCons "PollerId" 'PrefixI 'True) (S1 ('MetaSel ('Just "unPollerId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UUID)))

data SubscriberExecutionDetails Source #

Constructors

SubscriberExecutionDetails
Fields _sedSubscriberId :: !SubscriberId _sedSubscriberMetadata :: !SubscriberMetadata

Instances

Instances details

Show SubscriberExecutionDetails Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> SubscriberExecutionDetails -> ShowS # show :: SubscriberExecutionDetails -> String # showList :: [SubscriberExecutionDetails] -> ShowS #
Eq SubscriberExecutionDetails Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: SubscriberExecutionDetails -> SubscriberExecutionDetails -> Bool # (/=) :: SubscriberExecutionDetails -> SubscriberExecutionDetails -> Bool #

data CohortExecutionDetails Source #

Execution information related to a cohort on a poll cycle

Constructors

CohortExecutionDetails

Fields

_cedCohortId :: !CohortId
_cedVariables :: !CohortVariables
_cedResponseSize :: !(Maybe Int)
Nothing in case of an error
_cedPushedTo :: ![SubscriberExecutionDetails]
The response on this cycle has been pushed to these above subscribers New subscribers (those which haven't been around during the previous poll cycle) will always be part of this
_cedIgnored :: ![SubscriberExecutionDetails]
The response on this cycle has *not* been pushed to these above subscribers. This would when the response hasn't changed from the previous polled cycle
_cedBatchId :: !BatchId

Instances

Instances details

Show CohortExecutionDetails Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> CohortExecutionDetails -> ShowS # show :: CohortExecutionDetails -> String # showList :: [CohortExecutionDetails] -> ShowS #
Eq CohortExecutionDetails Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: CohortExecutionDetails -> CohortExecutionDetails -> Bool # (/=) :: CohortExecutionDetails -> CohortExecutionDetails -> Bool #

data BatchExecutionDetails Source #

Execution information related to a single batched execution

Constructors

BatchExecutionDetails

Fields

_bedPgExecutionTime :: Maybe DiffTime
postgres execution time of each batch (Nothing in case of non-PG dbs)
_bedDbExecutionTime :: DiffTime
database execution time of each batch
_bedPushTime :: DiffTime
time to taken to push to all cohorts belonging to this batch
_bedBatchId :: BatchId
id of the batch
_bedCohorts :: [CohortExecutionDetails]
execution details of the cohorts belonging to this batch
_bedBatchResponseSizeBytes :: Maybe Int

Instances

Instances details

Show BatchExecutionDetails Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> BatchExecutionDetails -> ShowS # show :: BatchExecutionDetails -> String # showList :: [BatchExecutionDetails] -> ShowS #
Eq BatchExecutionDetails Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: BatchExecutionDetails -> BatchExecutionDetails -> Bool # (/=) :: BatchExecutionDetails -> BatchExecutionDetails -> Bool #

data PollDetailsError Source #

Constructors

PollDetailsError
Fields _pdeBatchId :: BatchId _pdeErrorDetails :: QErr

Instances

Instances details

ToJSON PollDetailsError Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods toJSON :: PollDetailsError -> Value Source # toEncoding :: PollDetailsError -> Encoding Source # toJSONList :: [PollDetailsError] -> Value Source # toEncodingList :: [PollDetailsError] -> Encoding Source #
Show PollDetailsError Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> PollDetailsError -> ShowS # show :: PollDetailsError -> String # showList :: [PollDetailsError] -> ShowS #
Eq PollDetailsError Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: PollDetailsError -> PollDetailsError -> Bool # (/=) :: PollDetailsError -> PollDetailsError -> Bool #

data PollDetails Source #

Constructors

PollDetails

Fields

_pdPollerId :: PollerId
the unique ID (basically a thread that run as a Poller) for the Poller
_pdKind :: SubscriptionType
distinguish between the subscription type (i.e. live-query or streaming subscription)
_pdGeneratedSql :: Text
the multiplexed SQL query to be run against the database with all the variables together
_pdSnapshotTime :: DiffTime
the time taken to get a snapshot of cohorts from our SubscriptionsState data structure
_pdBatches :: [BatchExecutionDetails]
list of execution batches and their details
_pdTotalTime :: DiffTime
total time spent on a poll cycle
_pdLiveQueryOptions :: SubscriptionsOptions
_pdSource :: SourceName
_pdRole :: RoleName
_pdParameterizedQueryHash :: ParameterizedQueryHash
_pdLogLevel :: LogLevel
_pdErrors :: Maybe [PollDetailsError]

Instances

Instances details

Show PollDetails Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods showsPrec :: Int -> PollDetails -> ShowS # show :: PollDetails -> String # showList :: [PollDetails] -> ShowS #
Eq PollDetails Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods (==) :: PollDetails -> PollDetails -> Bool # (/=) :: PollDetails -> PollDetails -> Bool #
ToEngineLog PollDetails Hasura Source #
Instance details Defined in Hasura.GraphQL.Execute.Subscription.Poll.Common Methods toEngineLog :: PollDetails -> (LogLevel, EngineLogType Hasura, Value) Source #

type SubscriptionPostPollHook = PollDetails -> IO () Source #

defaultSubscriptionPostPollHook :: Logger Hasura -> SubscriptionPostPollHook Source #