catalog

type Catalog = sources.Catalog

type CatalogManager interface {
	// Load/Unload catalogs (for dynamic schema updates)
	AddCatalog(ctx context.Context, name string, catalog Catalog) error
	RemoveCatalog(ctx context.Context, name string) error
	ExistsCatalog(name string) bool
	// ReloadCatalog reloads a catalog. If the source supports incremental
	// changes (IncrementalCatalog), only the delta is compiled and applied.
	// Otherwise falls back to full recompilation.
	ReloadCatalog(ctx context.Context, name string) error
}

type ExtensionCatalog = sources.ExtensionCatalog

type IncrementalCatalog = sources.IncrementalCatalog

type Manager interface {
	// Catalog lifecycle
	AddCatalog(ctx context.Context, name string, catalog Catalog) error
	RemoveCatalog(ctx context.Context, name string) error
	ExistsCatalog(name string) bool
	ReloadCatalog(ctx context.Context, name string) error
	Engine(name string) (engines.Engine, error)
	// RegisterEngine adds an engine for planner routing without compilation.
	// Used by cluster workers where schema is already compiled in CoreDB.
	RegisterEngine(name string, engine engines.Engine)
}

type Operation struct {
	// Enriched AST operation definition
	Definition *ast.OperationDefinition

	// All fragments from the document (needed by the planner for FragmentSpread resolution)
	Fragments ast.FragmentDefinitionList

	// Transformed variables
	Variables map[string]any

	// Classified top-level query requests from the selection set
	Queries []sdl.QueryRequest

	// Combined bitmask of all query types in the operation
	QueryType sdl.QueryType
}

type ParseOption func(*parseConfig)

type Provider base.Provider

type Querier interface {
	Query(ctx context.Context, query string, vars map[string]any) (*types.Response, error)
}

type ReloadableCatalog = sources.ReloadableCatalog

type Service struct {
	// contains filtered or unexported fields
}

type ServiceOption func(*Service)

type VariableTransformer interface {
	TransformVariables(ctx context.Context, vars map[string]any) (map[string]any, error)
}