- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 592 for Pods (0.49 sec)
-
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) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux.go
for _, group := range groups { // If there are no pods in a particular range, // then do not wait for pods in that priority range. if len(group.Pods) == 0 { continue } var wg sync.WaitGroup wg.Add(len(group.Pods)) for _, pod := range group.Pods { go func(pod *v1.Pod, group podShutdownGroup) { defer wg.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 08:02:40 UTC 2022 - 15.5K 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/controller/statefulset/stateful_set.go
// List all pods to include the pods that don't match the selector anymore but // has a ControllerRef pointing to this StatefulSet. pods, err := ssc.podLister.Pods(set.Namespace).List(labels.Everything()) if err != nil { return nil, err } filter := func(pod *v1.Pod) bool { // Only claim if it matches our StatefulSet name. Otherwise release/ignore.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/types.go
// 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 Jun 05 18:37:07 UTC 2024 - 40.6K bytes - Viewed (0) -
pkg/kubelet/metrics/metrics.go
// RunningPodCount is a gauge that tracks the number of Pods currently with a running sandbox // It is used to expose the kubelet internal state: how many pods have running containers in the container runtime, and mainly for debugging purpose. RunningPodCount = metrics.NewGauge( &metrics.GaugeOpts{ Subsystem: KubeletSubsystem, Name: RunningPodsKey, Help: "Number of pods that have a running pod sandbox",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 15:13:25 UTC 2024 - 45.6K bytes - Viewed (0) -
staging/src/k8s.io/api/networking/v1/types_swagger_doc_generated.go
"podSelector": "podSelector is a label selector which selects pods. This field follows standard label selector semantics; if present but empty, it selects all pods.\n\nIf namespaceSelector is also set, then the NetworkPolicyPeer as a whole selects the pods matching podSelector in the Namespaces selected by NamespaceSelector. Otherwise it selects the pods matching podSelector in the policy's own namespace.",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 18:19:25 UTC 2023 - 23.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
if !status.IsSuccess() { return status.AsError() } return nil } // As the first step, remove all the lower priority pods from the node and // check if the given pod can be scheduled. podPriority := corev1helpers.PodPriority(pod) for _, pi := range nodeInfo.Pods { if corev1helpers.PodPriority(pi.Pod) < podPriority { potentialVictims = append(potentialVictims, pi) if err := removePod(pi); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 25 19:36:04 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager_test.go
runningPods []*kubecontainer.Pod pods []*v1.Pod listPods []types.UID /* pods to list */ podSetBeforeCleanup []types.UID /* pods to record before cleanup */ podSetAfterCleanup []types.UID /* pods set expected after cleanup */ podUnsetAfterCleanup []types.UID /* pods set expected after cleanup */ }{ { name: "no stale pods", listPods: []types.UID{"pod-1", "pod-2"}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 14.6K bytes - Viewed (0)