kueue: Dataflow¶

Controller Watches¶

Kubernetes resources this controller monitors for changes. Each watch triggers reconciliation when the watched resource is created, updated, or deleted.

Type	GVK	Source
For	/v1/Pod	`pkg/controller/jobs/leaderworkerset/leaderworkerset_pod_reconciler.go:57`
For	apps/v1/StatefulSet	`pkg/controller/jobs/statefulset/statefulset_reconciler.go:145`
For	kueue/v1beta1/AdmissionCheck	`pkg/controller/admissionchecks/provisioning/controller.go:849`
For	kueue/v1beta1/Workload	`test/performance/scheduler/runner/controller/controller.go:203`
For	kueue/v1beta1/Workload	`pkg/controller/admissionchecks/provisioning/controller.go:830`
For	leaderworkerset/v1/LeaderWorkerSet	`pkg/controller/jobs/leaderworkerset/leaderworkerset_reconciler.go:83`
Owns	autoscaling.x-k8s.io/v1beta1/ProvisioningRequest	`pkg/controller/admissionchecks/provisioning/controller.go:831`
Owns	kueue/v1beta1/Workload	`pkg/controller/jobframework/reconciler.go:1281`
Watches	/v1/LimitRange	`pkg/controller/core/workload_controller.go:797`
Watches	/v1/Namespace	`pkg/controller/core/clusterqueue_controller.go:591`
Watches	/v1/Pod	`pkg/controller/jobs/pod/pod_controller.go:131`
Watches	/v1/Pod	`pkg/controller/jobs/statefulset/statefulset_reconciler.go:147`
Watches	kueue/v1beta1/AdmissionCheck	`pkg/controller/admissionchecks/provisioning/controller.go:832`
Watches	kueue/v1beta1/ClusterQueue	`test/performance/scheduler/runner/controller/controller.go:205`
Watches	kueue/v1beta1/ClusterQueue	`pkg/controller/core/localqueue_controller.go:338`
Watches	kueue/v1beta1/ClusterQueue	`pkg/controller/core/workload_controller.go:799`
Watches	kueue/v1beta1/LocalQueue	`pkg/controller/core/workload_controller.go:800`
Watches	kueue/v1beta1/ProvisioningRequestConfig	`pkg/controller/admissionchecks/provisioning/controller.go:833`
Watches	kueue/v1beta1/ProvisioningRequestConfig	`pkg/controller/admissionchecks/provisioning/controller.go:850`
Watches	kueue/v1beta1/ResourceFlavor	`pkg/controller/tas/topology_controller.go:82`
Watches	kueue/v1beta1/Workload	`pkg/controller/jobs/job/job_controller.go:88`
Watches	kueue/v1beta1/Workload	`pkg/controller/jobs/pod/pod_controller.go:132`
Watches	node/v1/RuntimeClass	`pkg/controller/core/workload_controller.go:798`

Reconciliation Flow¶

How the controller interacts with the Kubernetes API during reconciliation.

sequenceDiagram
    %% Static dataflow for kueue

    participant KubernetesAPI as Kubernetes API
    participant controller_manager as controller-manager

    KubernetesAPI->>+controller_manager: Watch Pod (reconcile)
    KubernetesAPI->>+controller_manager: Watch StatefulSet (reconcile)
    KubernetesAPI->>+controller_manager: Watch AdmissionCheck (reconcile)
    KubernetesAPI->>+controller_manager: Watch Workload (reconcile)
    KubernetesAPI->>+controller_manager: Watch Workload (reconcile)
    KubernetesAPI->>+controller_manager: Watch LeaderWorkerSet (reconcile)
    controller_manager->>KubernetesAPI: Create/Update ProvisioningRequest
    controller_manager->>KubernetesAPI: Create/Update Workload
    KubernetesAPI-->>+controller_manager: Watch LimitRange (informer)
    KubernetesAPI-->>+controller_manager: Watch Namespace (informer)
    KubernetesAPI-->>+controller_manager: Watch Pod (informer)
    KubernetesAPI-->>+controller_manager: Watch Pod (informer)
    KubernetesAPI-->>+controller_manager: Watch AdmissionCheck (informer)
    KubernetesAPI-->>+controller_manager: Watch ClusterQueue (informer)
    KubernetesAPI-->>+controller_manager: Watch ClusterQueue (informer)
    KubernetesAPI-->>+controller_manager: Watch ClusterQueue (informer)
    KubernetesAPI-->>+controller_manager: Watch LocalQueue (informer)
    KubernetesAPI-->>+controller_manager: Watch ProvisioningRequestConfig (informer)
    KubernetesAPI-->>+controller_manager: Watch ProvisioningRequestConfig (informer)
    KubernetesAPI-->>+controller_manager: Watch ResourceFlavor (informer)
    KubernetesAPI-->>+controller_manager: Watch Workload (informer)
    KubernetesAPI-->>+controller_manager: Watch Workload (informer)
    KubernetesAPI-->>+controller_manager: Watch RuntimeClass (informer)

    Note over controller_manager: Exposed Services
    Note right of controller_manager: visibility-server:443/TCP [https]
    Note right of controller_manager: webhook-service:443/TCP []

Webhooks¶

Name	Type	Path	Failure Policy	Source
mdeployment.kb.io	mutating			`config/rhoai/mutating_webhook_patch.yaml`
mjob.kb.io	mutating			`config/rhoai/mutating_webhook_patch.yaml`
mpod.kb.io	mutating			`config/rhoai/mutating_webhook_patch.yaml`
vcohort.kb.io	validating	/validate-kueue-x-k8s-io-v1alpha1-cohort	fail	`pkg/webhooks/cohort_webhook.go`
vdeployment.kb.io	validating			`config/rhoai/validating_webhook_patch.yaml`
vjob.kb.io	validating			`config/rhoai/validating_webhook_patch.yaml`
vpod.kb.io	validating			`config/rhoai/validating_webhook_patch.yaml`

HTTP Endpoints¶

Method	Path	Source
GET	/ws/cluster-queue/:cluster_queue_name	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:41`
GET	/ws/cluster-queues	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:40`
GET	/ws/cohort/:cohort_name	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:45`
GET	/ws/cohorts	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:44`
GET	/ws/local-queue/:namespace/:queue_name	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:36`
GET	/ws/local-queue/:namespace/:queue_name/workloads	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:37`
GET	/ws/local-queues	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:35`
GET	/ws/resource-flavor/:flavor_name	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:49`
GET	/ws/resource-flavors	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:48`
GET	/ws/workload/:namespace/:workload_name	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:31`
GET	/ws/workload/:namespace/:workload_name/events	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:32`
GET	/ws/workloads	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:28`
GET	/ws/workloads/dashboard	`cmd/experimental/kueue-viz/backend/handlers/handlers.go:29`

Configuration¶

ConfigMaps and Helm values that control this component's runtime behavior.

Helm¶

Chart: kueue v0.1.0