Safe Haskell	None
Language	Haskell2010

Hasura.RQL.DDL.Schema.Cache.Common

Description

Types/functions shared between modules that implement Hasura.RQL.DDL.Schema.Cache. Other modules should not import this module directly.

Synopsis

data InvalidationKeys = InvalidationKeys {
- _ikMetadata :: InvalidationKey
- _ikRemoteSchemas :: HashMap RemoteSchemaName InvalidationKey
- _ikSources :: HashMap SourceName InvalidationKey
}
ikSources :: Lens' InvalidationKeys (HashMap SourceName InvalidationKey)
ikRemoteSchemas :: Lens' InvalidationKeys (HashMap RemoteSchemaName InvalidationKey)
ikMetadata :: Lens' InvalidationKeys InvalidationKey
initialInvalidationKeys :: InvalidationKeys
invalidateKeys :: CacheInvalidations -> InvalidationKeys -> InvalidationKeys
data TableBuildInput b = TableBuildInput {
- _tbiName :: TableName b
- _tbiIsEnum :: Bool
- _tbiConfiguration :: TableConfig b
- _tbiApolloFederationConfig :: Maybe ApolloFederationConfig
}
data NonColumnTableInputs b = NonColumnTableInputs {
- _nctiTable :: TableName b
- _nctiObjectRelationships :: [ObjRelDef b]
- _nctiArrayRelationships :: [ArrRelDef b]
- _nctiComputedFields :: [ComputedFieldMetadata b]
- _nctiRemoteRelationships :: [RemoteRelationship]
}
data TablePermissionInputs b = TablePermissionInputs {
- _tpiTable :: TableName b
- _tpiInsert :: [InsPermDef b]
- _tpiSelect :: [SelPermDef b]
- _tpiUpdate :: [UpdPermDef b]
- _tpiDelete :: [DelPermDef b]
}
mkTableInputs :: TableMetadata b -> (TableBuildInput b, NonColumnTableInputs b, TablePermissionInputs b)
data BuildOutputs = BuildOutputs {
- _boSources :: SourceCache
- _boActions :: ActionCache
- _boRemoteSchemas :: HashMap RemoteSchemaName (RemoteSchemaCtx, MetadataObject)
- _boAllowlist :: InlinedAllowlist
- _boCustomTypes :: AnnotatedCustomTypes
- _boCronTriggers :: HashMap TriggerName CronTriggerInfo
- _boEndpoints :: HashMap EndpointName (EndpointMetadata GQLQueryWithText)
- _boApiLimits :: ApiLimit
- _boMetricsConfig :: MetricsConfig
- _boRoles :: HashMap RoleName Role
- _boTlsAllowlist :: [TlsAllow]
- _boQueryCollections :: QueryCollections
}
boTlsAllowlist :: Lens' BuildOutputs [TlsAllow]
boSources :: Lens' BuildOutputs SourceCache
boRoles :: Lens' BuildOutputs (HashMap RoleName Role)
boRemoteSchemas :: Lens' BuildOutputs (HashMap RemoteSchemaName (RemoteSchemaCtx, MetadataObject))
boQueryCollections :: Lens' BuildOutputs QueryCollections
boMetricsConfig :: Lens' BuildOutputs MetricsConfig
boEndpoints :: Lens' BuildOutputs (HashMap EndpointName (EndpointMetadata GQLQueryWithText))
boCustomTypes :: Lens' BuildOutputs AnnotatedCustomTypes
boCronTriggers :: Lens' BuildOutputs (HashMap TriggerName CronTriggerInfo)
boApiLimits :: Lens' BuildOutputs ApiLimit
boAllowlist :: Lens' BuildOutputs InlinedAllowlist
boActions :: Lens' BuildOutputs ActionCache
data CacheBuildParams = CacheBuildParams {
- _cbpManager :: Manager
- _cbpPGSourceResolver :: SourceResolver ('Postgres 'Vanilla)
- _cbpMSSQLSourceResolver :: SourceResolver 'MSSQL
- _cbpServerConfigCtx :: ServerConfigCtx
}
newtype CacheBuild a = CacheBuild (ReaderT CacheBuildParams (ExceptT QErr IO) a)
runCacheBuild :: (MonadIO m, MonadError QErr m) => CacheBuildParams -> CacheBuild a -> m a
runCacheBuildM :: (MonadIO m, MonadError QErr m, HasHttpManagerM m, HasServerConfigCtx m, MonadResolveSource m) => CacheBuild a -> m a
data RebuildableSchemaCache = RebuildableSchemaCache {
- lastBuiltSchemaCache :: SchemaCache
- _rscInvalidationMap :: InvalidationKeys
- _rscRebuild :: Rule (ReaderT BuildReason CacheBuild) (Metadata, InvalidationKeys) SchemaCache
}
bindErrorA :: (ArrowChoice arr, ArrowKleisli m arr, ArrowError e arr, MonadError e m) => arr (m a) a
withRecordDependencies :: ArrowWriter (Seq CollectedInfo) arr => WriterA (Seq SchemaDependency) arr (e, s) a -> arr (e, (MetadataObject, (SchemaObjId, s))) a
noDuplicates :: MonadWriter (Seq CollectedInfo) m => (a -> MetadataObject) -> [a] -> m (Maybe a)
buildInfoMap :: (ArrowChoice arr, ArrowDistribute arr, ArrowWriter (Seq CollectedInfo) arr, Eq k, Hashable k) => (a -> k) -> (a -> MetadataObject) -> ((e, a) `arr` Maybe b) -> (e, [a]) `arr` HashMap k b
buildInfoMapPreservingMetadata :: (ArrowChoice arr, ArrowDistribute arr, ArrowWriter (Seq CollectedInfo) arr, Eq k, Hashable k) => (a -> k) -> (a -> MetadataObject) -> ((e, a) `arr` Maybe b) -> (e, [a]) `arr` HashMap k (b, MetadataObject)
addTableContext :: Backend b => TableName b -> Text -> Text

Documentation

data InvalidationKeys Source #

InvalidationKeys used to apply requested CacheInvalidations.

Constructors

InvalidationKeys
Fields _ikMetadata :: InvalidationKey _ikRemoteSchemas :: HashMap RemoteSchemaName InvalidationKey _ikSources :: HashMap SourceName InvalidationKey

Instances

Instances details

Eq InvalidationKeys Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods (==) :: InvalidationKeys -> InvalidationKeys -> Bool # (/=) :: InvalidationKeys -> InvalidationKeys -> Bool #
Show InvalidationKeys Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods showsPrec :: Int -> InvalidationKeys -> ShowS # show :: InvalidationKeys -> String # showList :: [InvalidationKeys] -> ShowS #
Generic InvalidationKeys Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Associated Types type Rep InvalidationKeys :: Type -> Type # Methods from :: InvalidationKeys -> Rep InvalidationKeys x # to :: Rep InvalidationKeys x -> InvalidationKeys #
Select InvalidationKeys Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Associated Types type Selector InvalidationKeys :: Type -> Type Source # Methods select :: Selector InvalidationKeys b -> InvalidationKeys -> b Source #
Cacheable InvalidationKeys Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods unchanged :: Accesses -> InvalidationKeys -> InvalidationKeys -> Bool Source #
type Rep InvalidationKeys Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common type Rep InvalidationKeys = D1 ('MetaData "InvalidationKeys" "Hasura.RQL.DDL.Schema.Cache.Common" "graphql-engine-1.0.0-inplace" 'False) (C1 ('MetaCons "InvalidationKeys" 'PrefixI 'True) (S1 ('MetaSel ('Just "_ikMetadata") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 InvalidationKey) :: (S1 ('MetaSel ('Just "_ikRemoteSchemas") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (HashMap RemoteSchemaName InvalidationKey)) :: S1 ('MetaSel ('Just "_ikSources") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (HashMap SourceName InvalidationKey)))))
type Selector InvalidationKeys Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common type Selector InvalidationKeys = FieldS InvalidationKeys

ikSources :: Lens' InvalidationKeys (HashMap SourceName InvalidationKey) Source #

ikRemoteSchemas :: Lens' InvalidationKeys (HashMap RemoteSchemaName InvalidationKey) Source #

ikMetadata :: Lens' InvalidationKeys InvalidationKey Source #

initialInvalidationKeys :: InvalidationKeys Source #

invalidateKeys :: CacheInvalidations -> InvalidationKeys -> InvalidationKeys Source #

data TableBuildInput b Source #

Constructors

TableBuildInput
Fields _tbiName :: TableName b _tbiIsEnum :: Bool _tbiConfiguration :: TableConfig b _tbiApolloFederationConfig :: Maybe ApolloFederationConfig

Instances

Instances details

Backend b => Eq (TableBuildInput b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods (==) :: TableBuildInput b -> TableBuildInput b -> Bool # (/=) :: TableBuildInput b -> TableBuildInput b -> Bool #
Backend b => Show (TableBuildInput b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods showsPrec :: Int -> TableBuildInput b -> ShowS # show :: TableBuildInput b -> String # showList :: [TableBuildInput b] -> ShowS #
Generic (TableBuildInput b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Associated Types type Rep (TableBuildInput b) :: Type -> Type # Methods from :: TableBuildInput b -> Rep (TableBuildInput b) x # to :: Rep (TableBuildInput b) x -> TableBuildInput b #
Backend b => NFData (TableBuildInput b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods rnf :: TableBuildInput b -> () #
Backend b => Cacheable (TableBuildInput b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods unchanged :: Accesses -> TableBuildInput b -> TableBuildInput b -> Bool Source #
type Rep (TableBuildInput b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common type Rep (TableBuildInput b) = D1 ('MetaData "TableBuildInput" "Hasura.RQL.DDL.Schema.Cache.Common" "graphql-engine-1.0.0-inplace" 'False) (C1 ('MetaCons "TableBuildInput" 'PrefixI 'True) ((S1 ('MetaSel ('Just "_tbiName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (TableName b)) :: S1 ('MetaSel ('Just "_tbiIsEnum") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 Bool)) :: (S1 ('MetaSel ('Just "_tbiConfiguration") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (TableConfig b)) :*: S1 ('MetaSel ('Just "_tbiApolloFederationConfig") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe ApolloFederationConfig)))))

data NonColumnTableInputs b Source #

Constructors

NonColumnTableInputs
Fields _nctiTable :: TableName b _nctiObjectRelationships :: [ObjRelDef b] _nctiArrayRelationships :: [ArrRelDef b] _nctiComputedFields :: [ComputedFieldMetadata b] _nctiRemoteRelationships :: [RemoteRelationship]

Instances

Instances details

Backend b => Eq (NonColumnTableInputs b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods (==) :: NonColumnTableInputs b -> NonColumnTableInputs b -> Bool # (/=) :: NonColumnTableInputs b -> NonColumnTableInputs b -> Bool #
Backend b => Show (NonColumnTableInputs b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods showsPrec :: Int -> NonColumnTableInputs b -> ShowS # show :: NonColumnTableInputs b -> String # showList :: [NonColumnTableInputs b] -> ShowS #
Generic (NonColumnTableInputs b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Associated Types type Rep (NonColumnTableInputs b) :: Type -> Type # Methods from :: NonColumnTableInputs b -> Rep (NonColumnTableInputs b) x # to :: Rep (NonColumnTableInputs b) x -> NonColumnTableInputs b #
type Rep (NonColumnTableInputs b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common type Rep (NonColumnTableInputs b) = D1 ('MetaData "NonColumnTableInputs" "Hasura.RQL.DDL.Schema.Cache.Common" "graphql-engine-1.0.0-inplace" 'False) (C1 ('MetaCons "NonColumnTableInputs" 'PrefixI 'True) ((S1 ('MetaSel ('Just "_nctiTable") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (TableName b)) :: S1 ('MetaSel ('Just "_nctiObjectRelationships") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 [ObjRelDef b])) :: (S1 ('MetaSel ('Just "_nctiArrayRelationships") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 [ArrRelDef b]) :: (S1 ('MetaSel ('Just "_nctiComputedFields") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 [ComputedFieldMetadata b]) :: S1 ('MetaSel ('Just "_nctiRemoteRelationships") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 [RemoteRelationship])))))

data TablePermissionInputs b Source #

Constructors

TablePermissionInputs
Fields _tpiTable :: TableName b _tpiInsert :: [InsPermDef b] _tpiSelect :: [SelPermDef b] _tpiUpdate :: [UpdPermDef b] _tpiDelete :: [DelPermDef b]

Instances

Instances details

(Backend b, Eq (TableName b)) => Eq (TablePermissionInputs b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods (==) :: TablePermissionInputs b -> TablePermissionInputs b -> Bool # (/=) :: TablePermissionInputs b -> TablePermissionInputs b -> Bool #
(Backend b, Show (TableName b)) => Show (TablePermissionInputs b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods showsPrec :: Int -> TablePermissionInputs b -> ShowS # show :: TablePermissionInputs b -> String # showList :: [TablePermissionInputs b] -> ShowS #
Generic (TablePermissionInputs b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Associated Types type Rep (TablePermissionInputs b) :: Type -> Type # Methods from :: TablePermissionInputs b -> Rep (TablePermissionInputs b) x # to :: Rep (TablePermissionInputs b) x -> TablePermissionInputs b #
Backend b => Cacheable (TablePermissionInputs b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods unchanged :: Accesses -> TablePermissionInputs b -> TablePermissionInputs b -> Bool Source #
type Rep (TablePermissionInputs b) Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common type Rep (TablePermissionInputs b) = D1 ('MetaData "TablePermissionInputs" "Hasura.RQL.DDL.Schema.Cache.Common" "graphql-engine-1.0.0-inplace" 'False) (C1 ('MetaCons "TablePermissionInputs" 'PrefixI 'True) ((S1 ('MetaSel ('Just "_tpiTable") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (TableName b)) :: S1 ('MetaSel ('Just "_tpiInsert") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 [InsPermDef b])) :: (S1 ('MetaSel ('Just "_tpiSelect") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 [SelPermDef b]) :: (S1 ('MetaSel ('Just "_tpiUpdate") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 [UpdPermDef b]) :: S1 ('MetaSel ('Just "_tpiDelete") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 [DelPermDef b])))))

mkTableInputs :: TableMetadata b -> (TableBuildInput b, NonColumnTableInputs b, TablePermissionInputs b) Source #

data BuildOutputs Source #

The direct output of buildSchemaCacheRule. Contains most of the things necessary to build a schema cache, but dependencies and inconsistent metadata objects are collected via a separate MonadWriter side channel.

Constructors

BuildOutputs

Fields

_boSources :: SourceCache
_boActions :: ActionCache
_boRemoteSchemas :: HashMap RemoteSchemaName (RemoteSchemaCtx, MetadataObject)
We preserve the MetadataObject from the original catalog metadata in the output so we can reuse it later if we need to mark the remote schema inconsistent during GraphQL schema generation (because of field conflicts).
_boAllowlist :: InlinedAllowlist
_boCustomTypes :: AnnotatedCustomTypes
_boCronTriggers :: HashMap TriggerName CronTriggerInfo
_boEndpoints :: HashMap EndpointName (EndpointMetadata GQLQueryWithText)
_boApiLimits :: ApiLimit
_boMetricsConfig :: MetricsConfig
_boRoles :: HashMap RoleName Role
_boTlsAllowlist :: [TlsAllow]
_boQueryCollections :: QueryCollections

boTlsAllowlist :: Lens' BuildOutputs [TlsAllow] Source #

boSources :: Lens' BuildOutputs SourceCache Source #

boRoles :: Lens' BuildOutputs (HashMap RoleName Role) Source #

boRemoteSchemas :: Lens' BuildOutputs (HashMap RemoteSchemaName (RemoteSchemaCtx, MetadataObject)) Source #

boQueryCollections :: Lens' BuildOutputs QueryCollections Source #

boMetricsConfig :: Lens' BuildOutputs MetricsConfig Source #

boEndpoints :: Lens' BuildOutputs (HashMap EndpointName (EndpointMetadata GQLQueryWithText)) Source #

boCustomTypes :: Lens' BuildOutputs AnnotatedCustomTypes Source #

boCronTriggers :: Lens' BuildOutputs (HashMap TriggerName CronTriggerInfo) Source #

boApiLimits :: Lens' BuildOutputs ApiLimit Source #

boAllowlist :: Lens' BuildOutputs InlinedAllowlist Source #

boActions :: Lens' BuildOutputs ActionCache Source #

data CacheBuildParams Source #

Parameters required for schema cache build

Constructors

CacheBuildParams
Fields _cbpManager :: Manager _cbpPGSourceResolver :: SourceResolver ('Postgres 'Vanilla) _cbpMSSQLSourceResolver :: SourceResolver 'MSSQL _cbpServerConfigCtx :: ServerConfigCtx

Instances

Instances details

MonadReader CacheBuildParams CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods ask :: CacheBuild CacheBuildParams # local :: (CacheBuildParams -> CacheBuildParams) -> CacheBuild a -> CacheBuild a # reader :: (CacheBuildParams -> a) -> CacheBuild a #

newtype CacheBuild a Source #

The monad in which @RebuildableSchemaCache is being run

Constructors

CacheBuild (ReaderT CacheBuildParams (ExceptT QErr IO) a)

Instances

Instances details

Monad CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods (>>=) :: CacheBuild a -> (a -> CacheBuild b) -> CacheBuild b # (>>) :: CacheBuild a -> CacheBuild b -> CacheBuild b # return :: a -> CacheBuild a #
Functor CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods fmap :: (a -> b) -> CacheBuild a -> CacheBuild b # (<$) :: a -> CacheBuild b -> CacheBuild a #
Applicative CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods pure :: a -> CacheBuild a # (<>) :: CacheBuild (a -> b) -> CacheBuild a -> CacheBuild b # liftA2 :: (a -> b -> c) -> CacheBuild a -> CacheBuild b -> CacheBuild c # (>) :: CacheBuild a -> CacheBuild b -> CacheBuild b # (<*) :: CacheBuild a -> CacheBuild b -> CacheBuild a #
MonadIO CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods liftIO :: IO a -> CacheBuild a #
MonadUnique CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods newUnique :: CacheBuild Unique Source #
HasHttpManagerM CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods askHttpManager :: CacheBuild Manager Source #
HasServerConfigCtx CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods askServerConfigCtx :: CacheBuild ServerConfigCtx Source #
MonadResolveSource CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods getPGSourceResolver :: CacheBuild (SourceResolver ('Postgres 'Vanilla)) Source # getMSSQLSourceResolver :: CacheBuild (SourceResolver 'MSSQL) Source #
MonadReader CacheBuildParams CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods ask :: CacheBuild CacheBuildParams # local :: (CacheBuildParams -> CacheBuildParams) -> CacheBuild a -> CacheBuild a # reader :: (CacheBuildParams -> a) -> CacheBuild a #
MonadError QErr CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods throwError :: QErr -> CacheBuild a # catchError :: CacheBuild a -> (QErr -> CacheBuild a) -> CacheBuild a #
MonadBaseControl IO CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Associated Types type StM CacheBuild a Methods liftBaseWith :: (RunInBase CacheBuild IO -> IO a) -> CacheBuild a restoreM :: StM CacheBuild a -> CacheBuild a
MonadBase IO CacheBuild Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common Methods liftBase :: IO α -> CacheBuild α
MonadMetadataStorageQueryAPI (MetadataStorageT (PGMetadataStorageAppT CacheBuild)) Source #
Instance details Defined in Hasura.App Methods createOneOffScheduledEvent :: OneOffEvent -> MetadataStorageT (PGMetadataStorageAppT CacheBuild) EventId Source # createCronEvents :: [CronEventSeed] -> MetadataStorageT (PGMetadataStorageAppT CacheBuild) () Source # dropFutureCronEvents :: ClearCronEvents -> MetadataStorageT (PGMetadataStorageAppT CacheBuild) () Source # deleteActionData :: ActionName -> MetadataStorageT (PGMetadataStorageAppT CacheBuild) () Source # fetchInvocations :: GetInvocationsBy -> ScheduledEventPagination -> MetadataStorageT (PGMetadataStorageAppT CacheBuild) (WithTotalCount [ScheduledEventInvocation]) Source # fetchScheduledEvents :: GetScheduledEvents -> MetadataStorageT (PGMetadataStorageAppT CacheBuild) Value Source # dropEvent :: ScheduledEventId -> ScheduledEventType -> MetadataStorageT (PGMetadataStorageAppT CacheBuild) () Source # fetchCatalogState :: MetadataStorageT (PGMetadataStorageAppT CacheBuild) CatalogState Source # updateCatalogState :: CatalogStateType -> Value -> MetadataStorageT (PGMetadataStorageAppT CacheBuild) () Source #
type StM CacheBuild a Source #
Instance details Defined in Hasura.RQL.DDL.Schema.Cache.Common type StM CacheBuild a = StM (ReaderT CacheBuildParams (ExceptT QErr IO)) a

runCacheBuild :: (MonadIO m, MonadError QErr m) => CacheBuildParams -> CacheBuild a -> m a Source #

runCacheBuildM :: (MonadIO m, MonadError QErr m, HasHttpManagerM m, HasServerConfigCtx m, MonadResolveSource m) => CacheBuild a -> m a Source #

data RebuildableSchemaCache Source #

Constructors

RebuildableSchemaCache
Fields lastBuiltSchemaCache :: SchemaCache _rscInvalidationMap :: InvalidationKeys _rscRebuild :: Rule (ReaderT BuildReason CacheBuild) (Metadata, InvalidationKeys) SchemaCache

bindErrorA :: (ArrowChoice arr, ArrowKleisli m arr, ArrowError e arr, MonadError e m) => arr (m a) a Source #

withRecordDependencies :: ArrowWriter (Seq CollectedInfo) arr => WriterA (Seq SchemaDependency) arr (e, s) a -> arr (e, (MetadataObject, (SchemaObjId, s))) a Source #

noDuplicates :: MonadWriter (Seq CollectedInfo) m => (a -> MetadataObject) -> [a] -> m (Maybe a) Source #

buildInfoMap :: (ArrowChoice arr, ArrowDistribute arr, ArrowWriter (Seq CollectedInfo) arr, Eq k, Hashable k) => (a -> k) -> (a -> MetadataObject) -> ((e, a) `arr` Maybe b) -> (e, [a]) `arr` HashMap k b Source #

Processes a list of catalog metadata into a map of processed information, marking any duplicate entries inconsistent.

buildInfoMapPreservingMetadata :: (ArrowChoice arr, ArrowDistribute arr, ArrowWriter (Seq CollectedInfo) arr, Eq k, Hashable k) => (a -> k) -> (a -> MetadataObject) -> ((e, a) `arr` Maybe b) -> (e, [a]) `arr` HashMap k (b, MetadataObject) Source #

Like buildInfo, but includes each processed info’s associated MetadataObject in the result. This is useful if the results will be further processed, and the MetadataObject is still needed to mark the object inconsistent.

addTableContext :: Backend b => TableName b -> Text -> Text Source #