- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 91 for nodeutil (0.24 sec)
-
pkg/registry/core/pod/storage/storage.go
"k8s.io/apiserver/pkg/registry/rest" "k8s.io/apiserver/pkg/storage" storeerr "k8s.io/apiserver/pkg/storage/errors" "k8s.io/apiserver/pkg/util/dryrun" policyclient "k8s.io/client-go/kubernetes/typed/policy/v1" podutil "k8s.io/kubernetes/pkg/api/pod" api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/kubernetes/pkg/apis/core/validation" "k8s.io/kubernetes/pkg/kubelet/client" "k8s.io/kubernetes/pkg/printers"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 20 14:29:25 UTC 2023 - 13.7K 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) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux.go
import ( "fmt" "path/filepath" "sort" "sync" "time" v1 "k8s.io/api/core/v1" utilfeature "k8s.io/apiserver/pkg/util/feature" "k8s.io/client-go/tools/record" "k8s.io/klog/v2" podutil "k8s.io/kubernetes/pkg/api/v1/pod" "k8s.io/kubernetes/pkg/apis/scheduling" "k8s.io/kubernetes/pkg/features" kubeletconfig "k8s.io/kubernetes/pkg/kubelet/apis/config" kubeletevents "k8s.io/kubernetes/pkg/kubelet/events"
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/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) -
src/text/template/parse/node.go
tr *Tree } func (t *Tree) newNil(pos Pos) *NilNode { return &NilNode{tr: t, NodeType: NodeNil, Pos: pos} } func (n *NilNode) Type() NodeType { // Override method on embedded NodeType for API compatibility. // TODO: Not really a problem; could change API without effect but // api tool complains. return NodeNil } func (n *NilNode) String() string { return "nil" }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 20:57:51 UTC 2024 - 24.2K bytes - Viewed (0)