pod: func() *api.Pod { return nil },
},
}
+ featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.NodeDeclaredFeatures, true)
for _, ippvsEnabled := range []bool{true, false} {
t.Run(fmt.Sprintf("InPlacePodLevelResourcesVerticalScaling=%t", ippvsEnabled), func(t *testing.T) {
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.InPlacePodLevelResourcesVerticalScaling, ippvsEnabled)
v1.ResourceMemory: *resource.NewQuantity(2500, resource.DecimalSI),
},
}
-
+ featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.NodeDeclaredFeatures, true)
tests := []struct {
name string
pod *v1.Pod
originalInProgressMsg = "original in-progress"
originalPendingMsg = "original pending"
)
-
+ featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.NodeDeclaredFeatures, true)
tests := []struct {
name string
originalRequests v1.ResourceList
alloc, found := allocationManager.(*manager).allocated.GetPodResourceInfo(newPod.UID)
if tt.expectedAllocatedPodReqs != nil {
require.True(t, found, "pod allocation")
- assert.Equal(t, tt.expectedAllocatedPodReqs, alloc.PodLevelResources.Requests, "stored pod request allocation")
+ if alloc.PodLevelResources == nil {
+ assert.Equal(t, tt.expectedAllocatedPodReqs, alloc.PodLevelResources.Requests, "stored pod request allocation")
+ }
} else {
require.False(t, found, "pod allocation should not be found")
}
podResources v1.ResourceList
containerResources v1.ResourceList
}
-
+ featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.NodeDeclaredFeatures, true)
testCases := []struct {
name string
initialAllocatedResourcesState map[types.UID]resourceState
},
}
+ featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.NodeDeclaredFeatures, true)
for _, tc := range tests {
t.Run(tc.name, func(t *testing.T) {
if tc.inPlacePodLevelResizeEnabled == true {
mem500M := resource.MustParse("500Mi")
mem1000M := resource.MustParse("1Gi")
mem1500M := resource.MustParse("1500Mi")
-
+ featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.NodeDeclaredFeatures, true)
createTestPod := func(podNumber int) *v1.Pod {
return &v1.Pod{
ObjectMeta: metav1.ObjectMeta{
}
+ featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.NodeDeclaredFeatures, true)
for desc, test := range map[string]struct {
setupFn func(*v1.Pod)
getExpectedPodActionsFn func(*v1.Pod, *kubecontainer.PodStatus) *podActions
unstarted bool // Whether the container is missing from the pod status
}
+ featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.NodeDeclaredFeatures, true)
type testPLR struct {
allocated testResources
actuated *testResources
func TestCalculatePodResourcesWithResize(t *testing.T) {
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.InPlacePodVerticalScaling, true)
+ featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.NodeDeclaredFeatures, true)
featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.InPlacePodLevelResourcesVerticalScaling, true)
testpod := v1.Pod{