kubernetes/staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/composition.go

const VariablesTypeName …

type CompositedCompiler …

type CompositedFilter …

func NewCompositedCompiler(envSet *environment.EnvSet) (*CompositedCompiler, error) { … }

func NewCompositedCompilerFromTemplate(context *CompositionEnv) *CompositedCompiler { … }

func (c *CompositedCompiler) CompileAndStoreVariables(variables []NamedExpressionAccessor, options OptionalVariableDeclarations, mode environment.Type) { … }

func (c *CompositedCompiler) CompileAndStoreVariable(variable NamedExpressionAccessor, options OptionalVariableDeclarations, mode environment.Type) CompilationResult { … }

func (c *CompositedCompiler) Compile(expressions []ExpressionAccessor, optionalDecls OptionalVariableDeclarations, envType environment.Type) Filter { … }

type CompositionEnv …

func (c *CompositionEnv) AddField(name string, celType *cel.Type) { … }

func NewCompositionEnv(typeName string, baseEnvSet *environment.EnvSet) (*CompositionEnv, error) { … }

func (c *CompositionEnv) CreateContext(parent context.Context) CompositionContext { … }

type CompositionContext …

type compositionContext …

func (c *compositionContext) Variables(activation any) ref.Val { … }

func (f *CompositedFilter) ForInput(ctx context.Context, versionedAttr *admission.VersionedAttributes, request *v1.AdmissionRequest, optionalVars OptionalVariableBindings, namespace *corev1.Namespace, runtimeCELCostBudget int64) ([]EvaluationResult, int64, error) { … }

func (c *compositionContext) reportCost(cost int64) { … }

func (c *compositionContext) GetAndResetCost() int64 { … }

type variableAccessor …

func (a *variableAccessor) Callback(_ *lazy.MapValue) ref.Val { … }

// convertCelTypeToDeclType converts a cel.Type to DeclType, for the use of
// the TypeProvider and the cost estimator.
// List and map types are created on-demand with their parameters converted recursively.
func convertCelTypeToDeclType(celType *cel.Type) *apiservercel.DeclType { … }