- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 183 for podutil (0.17 sec)
-
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) -
pkg/kubelet/status/status_manager_test.go
syncer.SetPodStatus(pod, anotherStatus) verifyUpdates(t, syncer, 1) newStatus := expectPodStatus(t, syncer, pod) oldReadyCondition := podutil.GetPodReadyCondition(oldStatus) newReadyCondition := podutil.GetPodReadyCondition(newStatus) if newReadyCondition.LastTransitionTime.IsZero() { t.Errorf("Unexpected: last transition time not set") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
var cID string cStatus, found := podutil.GetContainerStatus(podStatus.ContainerStatuses, containerName) if !found { cStatus, found = podutil.GetContainerStatus(podStatus.InitContainerStatuses, containerName) } if !found { cStatus, found = podutil.GetContainerStatus(podStatus.EphemeralContainerStatuses, containerName) } if !found {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils.go
func isRunningAndReady(pod *v1.Pod) bool { return pod.Status.Phase == v1.PodRunning && podutil.IsPodReady(pod) } func isRunningAndAvailable(pod *v1.Pod, minReadySeconds int32) bool { return podutil.IsPodAvailable(pod, minReadySeconds, metav1.Now()) } // isCreated returns true if pod has been created and is maintained by the API server
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 26.7K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
"k8s.io/client-go/tools/record" "k8s.io/client-go/util/workqueue" endpointsliceutil "k8s.io/endpointslice/util" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/api/v1/endpoints" podutil "k8s.io/kubernetes/pkg/api/v1/pod" api "k8s.io/kubernetes/pkg/apis/core" helper "k8s.io/kubernetes/pkg/apis/core/v1/helper" "k8s.io/kubernetes/pkg/controller" utillabels "k8s.io/kubernetes/pkg/util/labels"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager_test.go
return podWithSecretsAndUID(ns, podName, fmt.Sprintf("%s/%s", ns, podName), toAttach) } func podWithSecretsAndUID(ns, podName, podUID string, toAttach secretsToAttach) *v1.Pod { pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Namespace: ns, Name: podName, UID: types.UID(podUID), }, Spec: v1.PodSpec{}, } for _, name := range toAttach.imagePullSecretNames { pod.Spec.ImagePullSecrets = append(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
// pod itself might not get deleted for a while. podName, podUID := owningPod(claim) if podName != "" { pod, err := ec.podLister.Pods(claim.Namespace).Get(podName) switch { case err == nil: // Pod already replaced or not going to run? if pod.UID != podUID || isPodDone(pod) { // We are certain that the owning pod is not going to need
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
// Update pod condition to highPod. podutil.UpdatePodCondition(&highPod.Status, &v1.PodCondition{ Type: v1.PodScheduled, Status: v1.ConditionFalse, Reason: v1.PodReasonUnschedulable, Message: "fake scheduling failure", }) // Update pod condition to midPod. podutil.UpdatePodCondition(&midPod.Status, &v1.PodCondition{ Type: v1.PodScheduled,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)