- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 139 for KObj (0.03 sec)
-
pkg/controller/nodeipam/ipam/range_allocator.go
if nodeList != nil { for _, node := range nodeList.Items { if len(node.Spec.PodCIDRs) == 0 { logger.V(4).Info("Node has no CIDR, ignoring", "node", klog.KObj(&node)) continue } logger.V(4).Info("Node has CIDR, occupying it in CIDR map", "node", klog.KObj(&node), "podCIDR", node.Spec.PodCIDR) if err := ra.occupyCIDRs(&node); err != nil { // This will happen if:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
if set == nil { return } logger.V(4).Info("Pod objectMeta updated", "pod", klog.KObj(curPod), "oldObjectMeta", oldPod.ObjectMeta, "newObjectMeta", curPod.ObjectMeta) if oldPod.Status.Phase != curPod.Status.Phase { logger.V(4).Info("StatefulSet Pod phase changed", "pod", klog.KObj(curPod), "statefulSet", klog.KObj(set), "podPhase", curPod.Status.Phase) } ssc.enqueueStatefulSet(set)
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/kubelet/prober/worker.go
klog.V(3).InfoS("No status for pod", "pod", klog.KObj(w.pod)) return true } // Worker should terminate if pod is terminated. if status.Phase == v1.PodFailed || status.Phase == v1.PodSucceeded { klog.V(3).InfoS("Pod is terminated, exiting probe worker", "pod", klog.KObj(w.pod), "phase", status.Phase) return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 27 01:28:06 UTC 2023 - 10.7K bytes - Viewed (0) -
pkg/kubelet/config/common.go
klog.V(5).InfoS("Generated UID", "pod", klog.KObj(pod), "podUID", pod.UID, "source", source) } pod.Name = generatePodName(pod.Name, nodeName) klog.V(5).InfoS("Generated pod name", "pod", klog.KObj(pod), "podUID", pod.UID, "source", source) if pod.Namespace == "" { pod.Namespace = metav1.NamespaceDefault } klog.V(5).InfoS("Set namespace for pod", "pod", klog.KObj(pod), "source", source)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 5.8K bytes - Viewed (0) -
pkg/proxy/serviceport.go
"ipFamily", ipFamily, "loadBalancerIngressIPs", invalidIPs, "service", klog.KObj(service)) } if apiservice.NeedsHealthCheck(service) { p := service.Spec.HealthCheckNodePort if p == 0 { klog.ErrorS(nil, "Service has no healthcheck nodeport", "service", klog.KObj(service)) } else { info.healthCheckNodePort = int(p) } } return info
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 09 08:17:56 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
job := obj.(*batch.Job) logger.V(4).Info("Adding job", "job", klog.KObj(job)) if job.DeletionTimestamp == nil && needsCleanup(job) { tc.enqueue(logger, job) } } func (tc *Controller) updateJob(logger klog.Logger, old, cur interface{}) { job := cur.(*batch.Job) logger.V(4).Info("Updating job", "job", klog.KObj(job)) if job.DeletionTimestamp == nil && needsCleanup(job) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/util/util.go
} if len(pod.Spec.Volumes) <= 0 { logger.V(10).Info("Skipping processing of pod, it has no volumes", "pod", klog.KObj(pod)) return } nodeName := types.NodeName(pod.Spec.NodeName) if nodeName == "" { logger.V(10).Info("Skipping processing of pod, it is not scheduled to a node", "pod", klog.KObj(pod)) return } else if !desiredStateOfWorld.NodeExists(nodeName) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 12K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/fake_cpu_manager.go
} func (m *fakeManager) Allocate(pod *v1.Pod, container *v1.Container) error { klog.InfoS("Allocate", "pod", klog.KObj(pod), "containerName", container.Name) return nil } func (m *fakeManager) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) { klog.InfoS("AddContainer", "pod", klog.KObj(pod), "containerName", container.Name, "containerID", containerID) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
logger.Error(err, "Could not add DisruptionTarget condition due to preemption", "pod", klog.KObj(victim), "preemptor", klog.KObj(pod)) errCh.SendErrorWithCancel(err, cancel) return } } } if err := util.DeletePod(ctx, cs, victim); err != nil { logger.Error(err, "Preempted pod", "pod", klog.KObj(victim), "preemptor", klog.KObj(pod)) errCh.SendErrorWithCancel(err, cancel) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0)