- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 236 for podutil (0.24 sec)
-
pkg/controller/daemon/update.go
case newPod != nil: // this pod is up to date, check its availability if !podutil.IsPodAvailable(newPod, ds.Spec.MinReadySeconds, metav1.Time{Time: now}) { // an unavailable new pod is counted against maxUnavailable numUnavailable++ } default: // this pod is old, it is an update candidate switch { case !podutil.IsPodAvailable(oldPod, ds.Spec.MinReadySeconds, metav1.Time{Time: now}):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 16:53:53 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/controller/daemon/update_test.go
if pod.DeletionTimestamp != nil { continue } if podutil.IsPodReady(pod) == ready { continue } if !fn(pod) { continue } condition := v1.PodCondition{Type: v1.PodReady} if ready { condition.Status = v1.ConditionTrue } else { condition.Status = v1.ConditionFalse } if !podutil.UpdatePodCondition(&pod.Status, &condition) { t.Fatal("failed to update pod")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 10 21:10:35 UTC 2024 - 28.9K bytes - Viewed (0) -
plugin/pkg/admission/noderestriction/admission.go
} hasSecrets := false podutil.VisitPodSecretNames(pod, func(name string) (shouldContinue bool) { hasSecrets = true; return false }, podutil.AllContainers) if hasSecrets { return admission.NewForbidden(a, fmt.Errorf("node %q can not create pods that reference secrets", nodeName)) } hasConfigMaps := false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
if ds == nil { return } logger.V(4).Info("Pod updated", "pod", klog.KObj(curPod)) dsc.enqueueDaemonSet(ds) changedToReady := !podutil.IsPodReady(oldPod) && podutil.IsPodReady(curPod) // See https://github.com/kubernetes/kubernetes/pull/38076 for more details if changedToReady && ds.Spec.MinReadySeconds > 0 { // Add a second to avoid milliseconds skew in AddAfter.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph.go
g.addEdgeToDestinationIndex_locked(e) } podutil.VisitPodSecretNames(pod, func(secret string) bool { secretVertex := g.getOrCreateVertex_locked(secretVertexType, pod.Namespace, secret) e := newDestinationEdge(secretVertex, podVertex, nodeVertex) g.graph.SetEdge(e) g.addEdgeToDestinationIndex_locked(e) return true }) podutil.VisitPodConfigmapNames(pod, func(configmap string) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
pod: pod, container: c, createdAt: fakeCreatedAt, state: runtimeapi.ContainerState_CONTAINER_RUNNING, } } podutil.VisitContainers(&pod.Spec, podutil.AllFeatureEnabledContainers(), func(c *v1.Container, containerType podutil.ContainerType) bool { containers = append(containers, makeFakeContainer(t, m, newTemplate(c))) return true })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
plugin/pkg/admission/serviceaccount/admission.go
return admission.NewForbidden(a, fmt.Errorf("a mirror pod may not reference service accounts")) } hasSecrets := false podutil.VisitPodSecretNames(pod, func(name string) bool { hasSecrets = true return false }, podutil.AllContainers) if hasSecrets { return admission.NewForbidden(a, fmt.Errorf("a mirror pod may not reference secrets")) } for _, v := range pod.Spec.Volumes {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 17:49:30 UTC 2024 - 18.6K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
// the Pod status which in turn will trigger a requeue of the owning replica set thus // having its status updated with the newly available replica. if !podutil.IsPodReady(oldPod) && podutil.IsPodReady(curPod) && set.Spec.MinReadySeconds > 0 { logger.V(2).Info("StatefulSet will be enqueued after minReadySeconds for availability check", "statefulSet", klog.KObj(set), "minReadySeconds", set.Spec.MinReadySeconds)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
// a Pod transitioned to Ready. // Note that this still suffers from #29229, we are just moving the problem one level // "closer" to kubelet (from the deployment to the replica set controller). if !podutil.IsPodReady(oldPod) && podutil.IsPodReady(curPod) && rs.Spec.MinReadySeconds > 0 { logger.V(2).Info("pod will be enqueued after a while for availability check", "duration", rs.Spec.MinReadySeconds, "kind", rsc.Kind, "pod", klog.KObj(oldPod))
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/scheduler/framework/types.go
ContainerFn: func(requests v1.ResourceList, containerType podutil.ContainerType) { non0CPUReq, non0MemReq := schedutil.GetNonzeroRequests(&requests) switch containerType { case podutil.Containers: non0CPU += non0CPUReq non0Mem += non0MemReq case podutil.InitContainers: non0InitCPU = max(non0InitCPU, non0CPUReq) non0InitMem = max(non0InitMem, non0MemReq)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0)