- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 103 for pod_1 (0.05 sec)
-
pkg/kubelet/eviction/helpers_test.go
func TestOrderedByPriorityProcess(t *testing.T) { pod1 := newPod("low-priority-high-usage", lowPriority, nil, nil) pod2 := newPod("low-priority-low-usage", lowPriority, nil, nil) pod3 := newPod("high-priority-high-usage", highPriority, nil, nil) pod4 := newPod("high-priority-low-usage", highPriority, nil, nil) stats := map[*v1.Pod]statsapi.PodStats{ pod1: newPodProcessStats(pod1, 20), pod2: newPodProcessStats(pod2, 6),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 106.7K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
} volumes := rcInstance.actualStateOfWorld.GetPossiblyMountedVolumesForPod("pod1") if len(volumes) != 1 { return fmt.Errorf("expected 1 uncertain volume in asw got %d", len(volumes)) } // The volume should be marked as reconstructed in ASW if reconstructed := rcInstance.actualStateOfWorld.IsVolumeReconstructed("fake-plugin/pvc-abcdef", "pod1"); !reconstructed {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
// It takes arguments of the type "interface{}" to be used with SortableList, // but expects those arguments to be *v1.Pod. func MoreImportantPod(pod1, pod2 *v1.Pod) bool { p1 := corev1helpers.PodPriority(pod1) p2 := corev1helpers.PodPriority(pod2) if p1 != p2 { return p1 > p2 } return GetPodStartTime(pod1).Before(GetPodStartTime(pod2)) } // Retriable defines the retriable errors during a scheduling cycle. func Retriable(err error) bool {
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/kubelet/kubelet_pods_test.go
{name: "pod1", updateType: kubetypes.SyncPodCreate}, {name: "pod1", updateType: kubetypes.SyncPodKill, gracePeriod: &two}, {name: "pod1", updateType: kubetypes.SyncPodKill, gracePeriod: &two}, // after the second attempt {name: "pod1", updateType: kubetypes.SyncPodKill, gracePeriod: &two}, // from termination {name: "pod1", terminated: true},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
func TestSyncServicePodSelection(t *testing.T) { client, esController := newController(t, []string{"node-1"}, time.Duration(0)) ns := metav1.NamespaceDefault pod1 := newPod(1, ns, true, 0, false) esController.podStore.Add(pod1) // ensure this pod will not match the selector pod2 := newPod(2, ns, true, 0, false) pod2.Labels["foo"] = "boo" esController.podStore.Add(pod2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
pod1 := newPod("pod1", job1) pod1.OwnerReferences = nil informer.Core().V1().Pods().Informer().GetIndexer().Add(pod1) // Labels changed on orphan. Expect newly matching controllers to queue. prev := *pod1 prev.Labels = map[string]string{"foo2": "bar2"} bumpResourceVersion(pod1) jm.updatePod(logger, &prev, pod1) verifyEmptyQueueAndAwaitForQueueLen(ctx, t, jm, 2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go
s.addPods(t, "127.0.0.201", "pod1", "pod1", map[string]string{"app": "a"}, nil, true, corev1.PodRunning) s.assertEvent(t, s.podXdsName("pod1")) s.addService(t, "svc1", map[string]string{}, // labels map[string]string{}, // annotations []int32{80}, map[string]string{"app": "a"}, // selector "10.0.0.1", ) s.assertEvent(t, s.podXdsName("pod1"), "ns1/svc1.ns1.svc.company.com") s.clearEvents()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 15.6K bytes - Viewed (0) -
docs/distributed/decom-encrypted-sse-s3.sh
policy_count=$(./mc admin policy list myminio/ | wc -l) kill $pid (minio server http://localhost:9000/tmp/xl/{1...10}/disk{0...1} http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/expanded_1.log) & pid_1=$! (minio server --address ":9001" http://localhost:9000/tmp/xl/{1...10}/disk{0...1} http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/expanded_2.log) & pid_2=$! ./mc ready myminio
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeports/node_ports_test.go
t.Errorf("status does not match: %v, want: %v", gotStatus, wantStatus) } } func TestGetContainerPorts(t *testing.T) { tests := []struct { pod1 *v1.Pod pod2 *v1.Pod expected []*v1.ContainerPort }{ { pod1: st.MakePod().ContainerPort([]v1.ContainerPort{ { ContainerPort: 8001, HostPort: 8001, Protocol: v1.ProtocolTCP, }, {
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/volumemanager/reconciler/reconciler_test.go
dsw, asw, hasAddedPods, oex, mount.NewFakeMounter(nil), hostutil.NewFakeHostUtil(nil), volumePluginMgr, kubeletPodsDir) pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod1", UID: "pod1uid", }, Spec: v1.PodSpec{ Volumes: []v1.Volume{ { Name: "volume-name", VolumeSource: v1.VolumeSource{ GCEPersistentDisk: &v1.GCEPersistentDiskVolumeSource{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0)