- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 914 for Pods (0.06 sec)
-
pkg/controller/disruption/disruption.go
logger := klog.FromContext(ctx) pods, err := dc.getPodsForPdb(pdb) if err != nil { dc.recorder.Eventf(pdb, v1.EventTypeWarning, "NoPods", "Failed to get pods: %v", err) return err } if len(pods) == 0 { dc.recorder.Eventf(pdb, v1.EventTypeNormal, "NoPods", "No matching pods found") } expectedCount, desiredHealthy, unmanagedPods, err := dc.getExpectedPodCount(ctx, pdb, pods) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/requested_to_capacity_ratio_test.go
name: "resources requested, pods scheduled with more resources", pods: []*v1.Pod{ st.MakePod().Obj(), }, }, } for _, test := range tests { t.Run(test.name, func(t *testing.T) { state := framework.NewCycleState() snapshot := cache.NewSnapshot(test.pods, test.nodes) _, ctx := ktesting.NewTestContext(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 21.2K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache.go
// status from having pods with affinity to NOT having pods with affinity or the other // way around. updateNodesHavePodsWithAffinity := false // HavePodsWithRequiredAntiAffinityNodeInfoList must be re-created if a node changed its // status from having pods with required anti-affinity to NOT having pods with required // anti-affinity or the other way around.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/generated.proto
optional string completionMode = 9; // suspend specifies whether the Job controller should create Pods or not. If // a Job is created with suspend set to true, no Pods are created by the Job // controller. If a Job is suspended after creation (i.e. the flag goes from // false to true), the Job controller will delete all active Pods associated // with this Job. Users must design their workload to gracefully handle this.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 29.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
return nil } // list all pods to include the pods that don't match the rs`s selector // anymore but has the stale controller ref. // TODO: Do the List and Filter in a single pass, or use an index. allPods, err := rsc.podLister.Pods(rs.Namespace).List(labels.Everything()) if err != nil { return err } // Ignore inactive pods. filteredPods := controller.FilterActivePods(logger, allPods)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
plugin/pkg/admission/resourcequota/admission_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:28:42 UTC 2024 - 84.1K bytes - Viewed (0) -
pkg/scheduler/util/utils_test.go
var priority int32 = 1 currentTime := time.Now() tests := []struct { name string pods []*v1.Pod expectedStartTime *metav1.Time }{ { name: "Pods length is 0", pods: []*v1.Pod{}, expectedStartTime: nil, }, { name: "generate new startTime", pods: []*v1.Pod{ newPriorityPodWithStartTime("pod1", 1, currentTime.Add(-time.Second)), {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 14.5K bytes - Viewed (0) -
pkg/kubelet/cm/qos_container_manager_linux.go
} } return nil } func (m *qosContainerManagerImpl) setCPUCgroupConfig(configs map[v1.PodQOSClass]*CgroupConfig) error { pods := m.activePods() burstablePodCPURequest := int64(0) reuseReqs := make(v1.ResourceList, 4) for i := range pods { pod := pods[i] qosClass := v1qos.GetPodQOS(pod) if qosClass != v1.PodQOSBurstable { // we only care about the burstable qos tier continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 20:42:59 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/test/framework/components/istio/util.go
) ([]any, bool, error) { if !s.LoadBalancerSupported { pods, err := cluster.PodsForSelector(context.TODO(), ns, label) if err != nil { return nil, false, err } names := make([]string, 0, len(pods.Items)) for _, p := range pods.Items { names = append(names, p.Name) } scopes.Framework.Debugf("Querying remote service %s, pods:%v", svcName, names) if len(pods.Items) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 17:13:34 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/config/analysis/analyzers/sidecar/selector.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun May 05 03:44:57 UTC 2024 - 5K bytes - Viewed (0)