graphql-engine-1.0.0: GraphQL API over Postgres
Safe HaskellNone
LanguageHaskell2010

Hasura.RQL.DDL.Schema.Cache

Description

Top-level functions concerned specifically with operations on the schema cache, such as rebuilding it from the catalog and incorporating schema changes. See the module documentation for Hasura.RQL.DDL.Schema for more details.

Note: this module is mutually recursive with other Hasura.RQL.DDL.Schema.* modules, which both define pieces of the implementation of building the schema cache and define handlers that trigger schema cache rebuilds.

Documentation

buildRebuildableSchemaCache :: Logger Hasura -> Environment -> Metadata -> CacheBuild RebuildableSchemaCache Source #

buildRebuildableSchemaCacheWithReason :: BuildReason -> Logger Hasura -> Environment -> Metadata -> CacheBuild RebuildableSchemaCache Source #

newtype CacheRWT m a Source #

Constructors

CacheRWT (StateT (RebuildableSchemaCache, CacheInvalidations) m a) 

Instances

Instances details
MonadTrans CacheRWT Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

lift :: Monad m => m a -> CacheRWT m a #

MonadReader r m => MonadReader r (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

ask :: CacheRWT m r #

local :: (r -> r) -> CacheRWT m a -> CacheRWT m a #

reader :: (r -> a) -> CacheRWT m a #

MonadError e m => MonadError e (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

throwError :: e -> CacheRWT m a #

catchError :: CacheRWT m a -> (e -> CacheRWT m a) -> CacheRWT m a #

MonadBaseControl b m => MonadBaseControl b (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Associated Types

type StM (CacheRWT m) a

Methods

liftBaseWith :: (RunInBase (CacheRWT m) b -> b a) -> CacheRWT m a

restoreM :: StM (CacheRWT m) a -> CacheRWT m a

MonadBase b m => MonadBase b (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

liftBase :: b α -> CacheRWT m α

Monad m => Monad (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

(>>=) :: CacheRWT m a -> (a -> CacheRWT m b) -> CacheRWT m b #

(>>) :: CacheRWT m a -> CacheRWT m b -> CacheRWT m b #

return :: a -> CacheRWT m a #

Functor m => Functor (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

fmap :: (a -> b) -> CacheRWT m a -> CacheRWT m b #

(<$) :: a -> CacheRWT m b -> CacheRWT m a #

Monad m => Applicative (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

pure :: a -> CacheRWT m a #

(<*>) :: CacheRWT m (a -> b) -> CacheRWT m a -> CacheRWT m b #

liftA2 :: (a -> b -> c) -> CacheRWT m a -> CacheRWT m b -> CacheRWT m c #

(*>) :: CacheRWT m a -> CacheRWT m b -> CacheRWT m b #

(<*) :: CacheRWT m a -> CacheRWT m b -> CacheRWT m a #

MonadIO m => MonadIO (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

liftIO :: IO a -> CacheRWT m a #

HasHttpManagerM m => HasHttpManagerM (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

askHttpManager :: CacheRWT m Manager Source #

MonadTrace m => MonadTrace (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

trace :: Text -> CacheRWT m a -> CacheRWT m a Source #

currentContext :: CacheRWT m TraceContext Source #

currentReporter :: CacheRWT m Reporter Source #

attachMetadata :: TracingMetadata -> CacheRWT m () Source #

UserInfoM m => UserInfoM (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

askUserInfo :: CacheRWT m UserInfo Source #

HasServerConfigCtx m => HasServerConfigCtx (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

askServerConfigCtx :: CacheRWT m ServerConfigCtx Source #

Monad m => CacheRM (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

askSchemaCache :: CacheRWT m SchemaCache Source #

(MonadIO m, MonadError QErr m, HasHttpManagerM m, MonadResolveSource m, HasServerConfigCtx m) => CacheRWM (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

buildSchemaCacheWithOptions :: BuildReason -> CacheInvalidations -> Metadata -> CacheRWT m () Source #

setMetadataResourceVersionInSchemaCache :: MetadataResourceVersion -> CacheRWT m () Source #

MonadMetadataStorageQueryAPI m => MonadMetadataStorageQueryAPI (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

createOneOffScheduledEvent :: OneOffEvent -> CacheRWT m EventId Source #

createCronEvents :: [CronEventSeed] -> CacheRWT m () Source #

dropFutureCronEvents :: ClearCronEvents -> CacheRWT m () Source #

deleteActionData :: ActionName -> CacheRWT m () Source #

fetchInvocations :: GetInvocationsBy -> ScheduledEventPagination -> CacheRWT m (WithTotalCount [ScheduledEventInvocation]) Source #

fetchScheduledEvents :: GetScheduledEvents -> CacheRWT m Value Source #

dropEvent :: ScheduledEventId -> ScheduledEventType -> CacheRWT m () Source #

fetchCatalogState :: CacheRWT m CatalogState Source #

updateCatalogState :: CatalogStateType -> Value -> CacheRWT m () Source #

MonadMetadataStorage m => MonadMetadataStorage (CacheRWT m) Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

Methods

fetchMetadataResourceVersion :: CacheRWT m MetadataResourceVersion Source #

fetchMetadata :: CacheRWT m (Metadata, MetadataResourceVersion) Source #

fetchMetadataNotifications :: MetadataResourceVersion -> InstanceId -> CacheRWT m [(MetadataResourceVersion, CacheInvalidations)] Source #

setMetadata :: MetadataResourceVersion -> Metadata -> CacheRWT m MetadataResourceVersion Source #

notifySchemaCacheSync :: MetadataResourceVersion -> InstanceId -> CacheInvalidations -> CacheRWT m () Source #

getCatalogState :: CacheRWT m CatalogState Source #

setCatalogState :: CatalogStateType -> Value -> CacheRWT m () Source #

getMetadataDbUid :: CacheRWT m MetadataDbId Source #

checkMetadataStorageHealth :: CacheRWT m () Source #

getDeprivedCronTriggerStats :: [TriggerName] -> CacheRWT m [CronTriggerStats] Source #

getScheduledEventsForDelivery :: CacheRWT m ([CronEvent], [OneOffScheduledEvent]) Source #

insertCronEvents :: [CronEventSeed] -> CacheRWT m () Source #

insertOneOffScheduledEvent :: OneOffEvent -> CacheRWT m EventId Source #

insertScheduledEventInvocation :: Invocation 'ScheduledType -> ScheduledEventType -> CacheRWT m () Source #

setScheduledEventOp :: ScheduledEventId -> ScheduledEventOp -> ScheduledEventType -> CacheRWT m () Source #

unlockScheduledEvents :: ScheduledEventType -> [ScheduledEventId] -> CacheRWT m Int Source #

unlockAllLockedScheduledEvents :: CacheRWT m () Source #

clearFutureCronEvents :: ClearCronEvents -> CacheRWT m () Source #

getOneOffScheduledEvents :: ScheduledEventPagination -> [ScheduledEventStatus] -> CacheRWT m (WithTotalCount [OneOffScheduledEvent]) Source #

getCronEvents :: TriggerName -> ScheduledEventPagination -> [ScheduledEventStatus] -> CacheRWT m (WithTotalCount [CronEvent]) Source #

getInvocations :: GetInvocationsBy -> ScheduledEventPagination -> CacheRWT m (WithTotalCount [ScheduledEventInvocation]) Source #

deleteScheduledEvent :: ScheduledEventId -> ScheduledEventType -> CacheRWT m () Source #

insertAction :: ActionName -> SessionVariables -> [Header] -> Value -> CacheRWT m ActionId Source #

fetchUndeliveredActionEvents :: CacheRWT m [ActionLogItem] Source #

setActionStatus :: ActionId -> AsyncActionStatus -> CacheRWT m () Source #

fetchActionResponse :: ActionId -> CacheRWT m ActionLogResponse Source #

clearActionData :: ActionName -> CacheRWT m () Source #

setProcessingActionLogsToPending :: LockedActionIdArray -> CacheRWT m () Source #

MonadQueryTags m => MonadQueryTags (CacheRWT m) Source # 
Instance details

Defined in Hasura.GraphQL.Execute.Backend

Methods

createQueryTags :: QueryTagsAttributes -> Maybe QueryTagsConfig -> Tagged (CacheRWT m) QueryTagsComment Source #

type StM (CacheRWT m) a Source # 
Instance details

Defined in Hasura.RQL.DDL.Schema.Cache

type StM (CacheRWT m) a = StM (StateT (RebuildableSchemaCache, CacheInvalidations) m) a

runCacheRWT :: Functor m => RebuildableSchemaCache -> CacheRWT m a -> m (a, RebuildableSchemaCache, CacheInvalidations) Source #

buildSchemaCacheRule :: (ArrowChoice arr, ArrowDistribute arr, ArrowCache m arr, MonadIO m, MonadBaseControl IO m, MonadError QErr m, MonadReader BuildReason m, HasHttpManagerM m, MonadResolveSource m, HasServerConfigCtx m) => Logger Hasura -> Environment -> (Metadata, InvalidationKeys) `arr` SchemaCache Source #

buildRemoteSchemaRemoteRelationship :: forall arr m. (ArrowChoice arr, ArrowWriter (Seq CollectedInfo) arr, ArrowKleisli m arr, MonadError QErr m) => ((HashMap SourceName (AnyBackend PartiallyResolvedSource), RemoteSchemaMap), (RemoteSchemaName, RemoteSchemaIntrospection, Name, RemoteRelationship)) `arr` Maybe (RemoteFieldInfo Name) Source #

mkRemoteSchemaRemoteRelationshipMetadataObject :: (RemoteSchemaName, Name, RemoteRelationship) -> MetadataObject Source #

data BackendConfigAndSourceMetadata b Source #

Constructors

BackendConfigAndSourceMetadata 

Fields

joinBackendConfigsToSources :: BackendMap BackendConfigWrapper -> InsOrdHashMap SourceName BackendSourceMetadata -> InsOrdHashMap SourceName (AnyBackend BackendConfigAndSourceMetadata) Source #