- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for podutil (0.12 sec)
-
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) -
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) -
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/controller/statefulset/stateful_set_utils_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 50.9K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers.go
"k8s.io/apimachinery/pkg/api/resource" utilfeature "k8s.io/apiserver/pkg/util/feature" corev1helpers "k8s.io/component-helpers/scheduling/corev1" "k8s.io/klog/v2" statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1" podutil "k8s.io/kubernetes/pkg/api/v1/pod" v1resource "k8s.io/kubernetes/pkg/api/v1/resource" "k8s.io/kubernetes/pkg/features" evictionapi "k8s.io/kubernetes/pkg/kubelet/eviction/api" kubetypes "k8s.io/kubernetes/pkg/kubelet/types"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 53.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
klog.V(4).InfoS("Sandbox does not have metadata", "sandbox", s) continue } podUID := kubetypes.UID(s.Metadata.Uid) if _, ok := pods[podUID]; !ok { pods[podUID] = &kubecontainer.Pod{ ID: podUID, Name: s.Metadata.Name, Namespace: s.Metadata.Namespace, } } p := pods[podUID] converted, err := m.sandboxToKubeContainer(s) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
batchv1listers "k8s.io/client-go/listers/batch/v1" corelisters "k8s.io/client-go/listers/core/v1" "k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/record" "k8s.io/client-go/util/workqueue" "k8s.io/klog/v2" podutil "k8s.io/kubernetes/pkg/api/v1/pod" "k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/controller/job/metrics" "k8s.io/kubernetes/pkg/controller/job/util" "k8s.io/kubernetes/pkg/features" "k8s.io/utils/clock"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
// UpdatePod. func (p *podWorkers) completeSync(podUID types.UID) { p.podLock.Lock() defer p.podLock.Unlock() klog.V(4).InfoS("Pod indicated lifecycle completed naturally and should now terminate", "podUID", podUID) status, ok := p.podSyncStatuses[podUID] if !ok { klog.V(4).InfoS("Pod had no status in completeSync, programmer error?", "podUID", podUID) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
initCont1Devices := testManager.podDevices.containerDevices(podUID, initCont1, res1.resourceName) initCont2Devices := testManager.podDevices.containerDevices(podUID, initCont2, res1.resourceName) normalCont1Devices := testManager.podDevices.containerDevices(podUID, normalCont1, res1.resourceName) normalCont2Devices := testManager.podDevices.containerDevices(podUID, normalCont2, res1.resourceName) as.Equal(1, initCont1Devices.Len())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0)