admissioncheck

Documentation

Index

• Variables
• func FilterForController(ctx context.Context, c client.Client, states []kueue.AdmissionCheckState, ...) ([]string, error)
• func FilterProvReqAnnotations(annotations map[string]string) map[string]string
• func IndexerByConfigFunction(controllerName string, gvk schema.GroupVersionKind) client.IndexerFunc
• func NewAdmissionChecks(cq *kueue.ClusterQueue) map[string]sets.Set[kueue.ResourceFlavorReference]
• type ConfigHelper
  • func NewConfigHelper[PtrT objAsPtr[T], T any](c client.Client) (*ConfigHelper[PtrT, T], error)
  • func (ch *ConfigHelper[PtrT, T]) ConfigByName(ctx context.Context, name string) (PtrT, error)
  • func (ch *ConfigHelper[PtrT, T]) ConfigForAdmissionCheck(ctx context.Context, checkName string) (PtrT, error)
  • func (ch *ConfigHelper[PtrT, T]) ConfigFromRef(ctx context.Context, ref *kueue.AdmissionCheckParametersReference) (PtrT, error)

Variables

var (
	ErrNilParametersRef = errors.New("missing parameters reference")
	ErrBadParametersRef = errors.New("bad parameters reference")
)

Functions

func FilterForController

func FilterForController(ctx context.Context, c client.Client, states []kueue.AdmissionCheckState, controllerName string) ([]string, error)

FilterForController - returns a list of check names controlled by ControllerName.

func FilterProvReqAnnotations

func FilterProvReqAnnotations(annotations map[string]string) map[string]string

FilterProvReqAnnotations returns annotations containing the Provisioning Request annotation prefix.

func IndexerByConfigFunction

func IndexerByConfigFunction(controllerName string, gvk schema.GroupVersionKind) client.IndexerFunc

func NewAdmissionChecks

func NewAdmissionChecks(cq *kueue.ClusterQueue) map[string]sets.Set[kueue.ResourceFlavorReference]

NewAdmissionChecks aggregates AdmissionChecks from .spec.AdmissionChecks and .spec.AdmissionChecksStrategy

Types

type ConfigHelper

type ConfigHelper[PtrT objAsPtr[T], T any] struct {
	// contains filtered or unexported fields
}

func NewConfigHelper

func NewConfigHelper[PtrT objAsPtr[T], T any](c client.Client) (*ConfigHelper[PtrT, T], error)

func (*ConfigHelper[PtrT, T]) ConfigByName

func (ch *ConfigHelper[PtrT, T]) ConfigByName(ctx context.Context, name string) (PtrT, error)

ConfigByName - get the config identified by its name

func (*ConfigHelper[PtrT, T]) ConfigForAdmissionCheck

func (ch *ConfigHelper[PtrT, T]) ConfigForAdmissionCheck(ctx context.Context, checkName string) (PtrT, error)

ConfigForAdmissionCheck - get the configuration of the admission check identified by its name if it uses the helpers configuration type.

func (*ConfigHelper[PtrT, T]) ConfigFromRef

func (ch *ConfigHelper[PtrT, T]) ConfigFromRef(ctx context.Context, ref *kueue.AdmissionCheckParametersReference) (PtrT, error)

ConfigFromRef - get the config identified by ref if valid.