github-personal/kubernetes
1
0
Fork 0
mirror of https://github.com/outbackdingo/kubernetes.git synced 2026-01-27 10:19:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #132931 from pohly/dra-e2e-device-plugin

Browse Source 
DRA E2E: test mixture of extended resources + ResourceClaim
This commit is contained in:
Kubernetes Prow Robot
2025-07-14 12:06:30 -07:00
committed by GitHub
parent bf0be9fb56 af249fb2e9
commit 4ffb58f6d7
2 changed files with 77 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
test/e2e/dra/deploy_device_plugin.go Normal file
View File

@@ -0,0 +1,62 @@
/*
Copyright 2025 The Kubernetes Authors.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package dra
import (
"context"
appsv1 "k8s.io/api/apps/v1"
v1 "k8s.io/api/core/v1"
"k8s.io/kubernetes/test/e2e/framework"
"k8s.io/kubernetes/test/e2e/storage/utils"
)
// deployDevicePlugin deploys https://github.com/kubernetes/kubernetes/tree/111a2a0d2dfe13639724506f674bc4f342ccfbab/test/images/sample-device-plugin
// on the chosen nodes.
//
// A test using this must run serially because the example plugin uses the hard-coded "example.com/resource"
// extended resource name (returned as result) and deploying it twice for the same nodes from different
// tests would conflict.
func deployDevicePlugin(ctx context.Context, f *framework.Framework, nodeNames []string) v1.ResourceName {
err := utils.CreateFromManifests(ctx, f, f.Namespace, func(item interface{}) error {
switch item := item.(type) {
case *appsv1.DaemonSet:
item.Spec.Template.Spec.Affinity = &v1.Affinity{
NodeAffinity: &v1.NodeAffinity{
RequiredDuringSchedulingIgnoredDuringExecution: &v1.NodeSelector{
NodeSelectorTerms: []v1.NodeSelectorTerm{
{
MatchExpressions: []v1.NodeSelectorRequirement{
{
Key: "kubernetes.io/hostname",
Operator: v1.NodeSelectorOpIn,
Values: nodeNames,
},
},
},
},
},
},
}
}
return nil
}, "test/e2e/testing-manifests/sample-device-plugin/sample-device-plugin.yaml")
framework.ExpectNoError(err, "deploy example device plugin DaemonSet")
// Hard-coded in https://github.com/kubernetes/kubernetes/blob/111a2a0d2dfe13639724506f674bc4f342ccfbab/test/images/sample-device-plugin/sampledeviceplugin.go#L34C17-L34C39.
return "example.com/resource"
}

15
test/e2e/dra/dra.go
View File

@@ -987,6 +987,21 @@ var _ = framework.SIGDescribe("node")(framework.WithLabel("DRA"), framework.With
gomega.Expect(getResourceClaim).ToNot(gomega.BeNil())
gomega.Expect(getResourceClaim.Status.Devices).To(gomega.Equal(updatedResourceClaim.Status.Devices))
})
if withKubelet {
// Serial because the example device plugin can only be deployed with one instance at a time.
f.It("supports extended resources together with ResourceClaim", f.WithSerial(), func(ctx context.Context) {
extendedResourceName := deployDevicePlugin(ctx, f, nodes.NodeNames[0:1])
pod := b.podExternal()
resources := v1.ResourceList{extendedResourceName: resource.MustParse("1")}
pod.Spec.Containers[0].Resources.Requests = resources
pod.Spec.Containers[0].Resources.Limits = resources
claim := b.externalClaim()
b.create(ctx, claim, pod)
b.testPod(ctx, f, pod)
})
}
}
// The following tests only make sense when there is more than one node.