- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 453 for pod4 (0.07 sec)
-
pkg/kubelet/kubelet_test.go
// resources) pods[7].Status.Phase = v1.PodFailed kubelet.podWorkers.(*fakePodWorkers).terminationRequested = map[types.UID]bool{ pods[7].UID: true, } expected := []*v1.Pod{pods[2], pods[3], pods[4], pods[7]} kubelet.podManager.SetPods(pods) actual := kubelet.filterOutInactivePods(pods) assert.Equal(t, expected, actual) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/controller/daemon/update_test.go
return ds }(), nodeToPods: func() map[string][]*v1.Pod { mapping := make(map[string][]*v1.Pod) pod0 := newPod("pod-0", "node-0", simpleDaemonSetLabel, nil) pod1 := newPod("pod-1", "node-1", simpleDaemonSetLabel, nil) markPodReady(pod0) markPodReady(pod1) mapping["node-0"] = []*v1.Pod{pod0} mapping["node-1"] = []*v1.Pod{pod1} return mapping }(), maxUnavailable: 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 10 21:10:35 UTC 2024 - 28.9K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
}) pod2 := makePod(v1.ResourceList{ v1.ResourceName(res2.resourceName): res2.resourceQuantity, }) activePods := []*v1.Pod{pod1, pod2} podsStub.updateActivePods(activePods) err = testManager.Allocate(pod1, &pod1.Spec.Containers[0]) as.Nil(err) err = testManager.Allocate(pod2, &pod2.Spec.Containers[0]) as.Nil(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 35.9K bytes - Viewed (0) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go
} } /* Concurrent operations tests */ // "None" means volume, pod, and node names are all empty // "Volume" means volume name is set, but pod name and node name are empty // "Volume Pod" means volume and pod names are set, but the node name is empty // "Volume Node" means volume and node names are set, but the pod name is empty // The same volume, pod, and node names are used (where they are not empty). // Covered cases:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 36.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go
// Call MarkVolumeAsDetached() on a volume which mounted by pod(s) should be skipped func Test_MarkVolumeAsDetached_Negative_PodInVolume(t *testing.T) { // Arrange volumePluginMgr, plugin := volumetesting.GetTestVolumePluginMgr(t) devicePath := "fake/device/path" asw := NewActualStateOfWorld("mynode", volumePluginMgr) pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod1", UID: "pod1uid", }, Spec: v1.PodSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
func GetPodFullName(pod *v1.Pod) string { // Use underscore as the delimiter because it is not allowed in pod name // (DNS subdomain format). return pod.Name + "_" + pod.Namespace } // GetPodStartTime returns start time of the given pod or current timestamp // if it hasn't started yet. func GetPodStartTime(pod *v1.Pod) *metav1.Time { if pod.Status.StartTime != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeports/node_ports_test.go
result := getContainerPorts(test.pod1, test.pod2) if diff := cmp.Diff(test.expected, result); diff != "" { t.Errorf("container ports: container ports does not match (-want,+got): %s", diff) } }) } } func Test_isSchedulableAfterPodDeleted(t *testing.T) { podWithHostPort := st.MakePod().HostPort(8080) testcases := map[string]struct { pod *v1.Pod oldObj interface{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 11:02:11 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static_test.go
} for i := range testCase.pod.Spec.InitContainers { err = p.Allocate(s, testCase.pod, &testCase.pod.Spec.InitContainers[i]) if !reflect.DeepEqual(err, testCase.expectedError) { t.Fatalf("The actual error %v is different from the expected one %v", err, testCase.expectedError) } } for i := range testCase.pod.Spec.Containers {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 17 05:49:15 UTC 2023 - 100.4K bytes - Viewed (0) -
plugin/pkg/admission/serviceaccount/admission_test.go
// clear generated volume names for i := range pod.Spec.Volumes { if len(pod.Spec.Volumes[i].Name) > 0 { pod.Spec.Volumes[i].Name = "cleared" } } for i := range pod.Spec.Containers[0].VolumeMounts { if len(pod.Spec.Containers[0].VolumeMounts[i].Name) > 0 { pod.Spec.Containers[0].VolumeMounts[i].Name = "cleared" } } if !reflect.DeepEqual(expectedVolumes, pod.Spec.Volumes) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 17:49:30 UTC 2024 - 36.9K bytes - Viewed (0)