graphql-engine/server/src-lib/Hasura/GraphQL/Execute/Subscription/Poll.hs
Karthikeyan Chinnakonda 362aca9db3 server: streaming subscriptions execution (Incremental PR - 2)
PR-URL: https://github.com/hasura/graphql-engine-mono/pull/4016
GitOrigin-RevId: 778300dd5ea094bc76b8f96c046313132863f832
2022-04-07 14:43:01 +00:00

48 lines
1.1 KiB
Haskell

-- | Multiplexed subscription poller threads; see "Hasura.GraphQL.Execute.Subscription" for details.
module Hasura.GraphQL.Execute.Subscription.Poll
( -- * Pollers
Poller (..),
PollerId (..),
PollerIOState (..),
pollLiveQuery,
pollStreamingQuery,
PollerKey (..),
PollerMap,
dumpPollerMap,
PollDetails (..),
BatchExecutionDetails (..),
CohortExecutionDetails (..),
SubscriptionPostPollHook,
defaultSubscriptionPostPollHook,
-- * Cohorts
Cohort (..),
CohortId,
newCohortId,
CohortVariables,
CohortKey,
CohortMap,
-- * Subscribers
Subscriber (..),
SubscriberId,
newSubscriberId,
SubscriberMetadata,
mkSubscriberMetadata,
unSubscriberMetadata,
SubscriberMap,
OnChange,
SubscriptionGQResponse,
SubscriptionResponse (..),
SubscriptionMetadata (..),
SubscriberExecutionDetails (..),
-- * Batch
BatchId (..),
)
where
import Hasura.GraphQL.Execute.Subscription.Poll.Common
import Hasura.GraphQL.Execute.Subscription.Poll.LiveQuery
import Hasura.GraphQL.Execute.Subscription.Poll.StreamingQuery