- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,536 for pcds (0.05 sec)
-
pkg/kubelet/cm/container_manager_linux.go
for _, pid := range allPids { if pid == 1 || isKernelPid(pid) { continue } pids = append(pids, pid) } // Check if we have moved all the non-kernel PIDs. if len(pids) == 0 { return nil } klog.V(3).InfoS("Moving non-kernel processes", "pids", pids) for _, pid := range pids { err := manager.Apply(pid) if err != nil { name := ""
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/kubelet/cm/node_container_manager_linux.go
nodeAllocatable = cm.getNodeAllocatableInternalAbsolute() } cgroupConfig := &CgroupConfig{ Name: cm.cgroupRoot, // The default limits for cpu shares can be very low which can lead to CPU starvation for pods. ResourceParameters: getCgroupConfig(nodeAllocatable), } if cm.cgroupManager.Exists(cgroupConfig.Name) { return nil } if err := cm.cgroupManager.Create(cgroupConfig); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 10.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/request/requestinfo_test.go
{"GET", "/api/v1/watch/namespaces/other/pods", "watch", "api", "", "v1", "other", "pods", "", "", []string{"pods"}}, {"GET", "/api/v1/namespaces/other/pods?watch=1", "watch", "api", "", "v1", "other", "pods", "", "", []string{"pods"}}, {"GET", "/api/v1/namespaces/other/pods?watch=0", "list", "api", "", "v1", "other", "pods", "", "", []string{"pods"}}, // subresource identification
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 15 12:19:21 UTC 2018 - 11.3K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
} sort.Sort(ascendingOrdinal(pods)) // expected number of pod is 0,1,2,3 if !reflect.DeepEqual(pods, originalPods[:4]) { t.Fatalf("Expected pods %v, got pods %v", originalPods[:4], pods) } // create new pods if _, err = ssc.UpdateStatefulSet(context.TODO(), set, pods); err != nil { t.Fatal(err) } pods, err = spc.podsLister.Pods(set.Namespace).List(selector) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
summaryStatsMaker := makePIDStats pods := []*v1.Pod{} podStats := map[*v1.Pod]statsapi.PodStats{} for _, podToMake := range tc.podsToMake { pod, podStat := podMaker(podToMake.name, podToMake.priority, podToMake.pidUsage) pods = append(pods, pod) podStats[pod] = podStat } podToEvict := pods[tc.evictPodIndex] activePodsFunc := func() []*v1.Pod { return pods }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/watch_tracker_test.go
httpRequest("GET", "api/v1/pods", "watch=true"), httpRequest("GET", "api/v1/namespaces/foo/pods", "watch=true"), httpRequest("GET", "api/v1/namespaces/foo/pods", "watch=true&fieldSelector=metadata.name=mypod"), httpRequest("GET", "api/v1/namespaces/bar/pods", "watch=true&fieldSelector=metadata.name=mypod"), httpRequest("GET", "apis/group/v1/namespaces/foo/pods", "watch=true"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 03 14:02:51 UTC 2021 - 10.4K bytes - Viewed (0) -
pkg/kubelet/active_deadline_test.go
// this pod has no start time pods[3].Status.StartTime = nil pods[3].Spec.ActiveDeadlineSeconds = ¬YetActiveDeadlineSeconds testCases := []struct { pod *v1.Pod expected bool }{{pods[0], true}, {pods[1], false}, {pods[2], false}, {pods[3], false}, {pods[4], false}} for i, testCase := range testCases { if actual := handler.ShouldSync(testCase.pod); actual != testCase.expected {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 08 09:06:42 UTC 2022 - 4.5K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller_test.go
creationTime := time.Unix(0, 0) nodes := []*v1.Node{testutil.NewNode("node")} pods := make([]*v1.Pod, 0, len(test.pods)) for _, pod := range test.pods { creationTime = creationTime.Add(1 * time.Hour) pods = append(pods, &v1.Pod{ ObjectMeta: metav1.ObjectMeta{Name: pod.name, Namespace: metav1.NamespaceDefault, CreationTimestamp: metav1.Time{Time: creationTime}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption.go
podsToEvict = append(podsToEvict, pods[bestPodIndex]) pods[bestPodIndex] = pods[len(pods)-1] pods = pods[:len(pods)-1] } return podsToEvict, nil } type admissionRequirement struct { resourceName v1.ResourceName quantity int64 } type admissionRequirementList []*admissionRequirement // distance returns distance of the pods requests from the admissionRequirements.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 16:53:19 UTC 2023 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/api/policy/v1beta1/types.go
// A null selector selects no pods. // An empty selector ({}) also selects no pods, which differs from standard behavior of selecting all pods. // In policy/v1, an empty selector will select all pods in the namespace. // +optional Selector *metav1.LabelSelector `json:"selector,omitempty" protobuf:"bytes,2,opt,name=selector"` // An eviction is allowed if at most "maxUnavailable" pods selected by
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 20:44:13 UTC 2023 - 11.1K bytes - Viewed (0)