- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 139 for KObj (0.05 sec)
-
pkg/controller/bootstrap/util.go
return "", "", false } tokenID = bootstrapsecretutil.GetData(secret, bootstrapapi.BootstrapTokenIDKey) if len(tokenID) == 0 { logger.V(3).Info("No key in Secret", "key", bootstrapapi.BootstrapTokenIDKey, "secret", klog.KObj(secret)) return "", "", false } if nameTokenID != tokenID { logger.V(3).Info("Token ID doesn't match secret name", "tokenID", tokenID, "secretName", secret.Name) return "", "", false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 02:18:40 UTC 2023 - 2.2K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
logger.V(5).Info("Pod is owned by both", "pod", klog.KObj(pod), "kind", rsc.Kind, "replicaSets", klog.KObjSlice([]klog.KMetadata{otherRS, relatedRS})) continue } seen[pod.UID] = relatedRS relatedPods = append(relatedPods, pod) } } logger.V(4).Info("Found related pods", "kind", rsc.Kind, "replicaSet", klog.KObj(rs), "pods", klog.KObjSlice(relatedPods)) return relatedPods, nil }
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/controller/podgc/gc_controller.go
if err := gcc.markFailedAndDeletePod(ctx, pod); err != nil { utilruntime.HandleError(err) metrics.DeletingPodsErrorTotal.WithLabelValues(pod.Namespace, metrics.PodGCReasonTerminatingUnscheduled).Inc() } else { logger.Info("Forced deletion of unscheduled terminating Pod succeeded", "pod", klog.KObj(pod)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeaffinity/node_affinity.go
return framework.Queue, nil } // TODO: also check if the original node meets the pod's requestments once preCheck is completely removed. // See: https://github.com/kubernetes/kubernetes/issues/110175 logger.V(4).Info("node was created or updated, but it doesn't make this pod schedulable", "pod", klog.KObj(pod), "node", klog.KObj(modifiedNode))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 18 12:00:10 UTC 2023 - 12.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go
return nil } else if err != nil { // If update node status fails, reset flag statusUpdateNeeded back to true // to indicate this node status needs to be updated again nsu.actualStateOfWorld.SetNodeStatusUpdateNeeded(logger, nodeName) logger.V(2).Info("Could not update node status; re-marking for update", "node", klog.KObj(nodeObj), "err", err) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
if !ok { return } if loggerV := logger.V(6); loggerV.Enabled() { loggerV.Info("ResourceSlice update", "slice", klog.KObj(newSlice), "diff", cmp.Diff(oldSlice, newSlice)) } else { logger.V(5).Info("ResourceSlice update", "slice", klog.KObj(newSlice)) } c.queue.Add(newSlice.DriverName) }, DeleteFunc: func(obj any) { if tombstone, ok := obj.(cache.DeletedFinalStateUnknown); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/controller/ttl/ttl_controller.go
logger := klog.FromContext(ctx) if err != nil { logger.V(2).Info("Failed to change ttl annotation for node", "node", klog.KObj(node), "err", err) return err } logger.V(2).Info("Changed ttl annotation", "node", klog.KObj(node), "TTL", time.Duration(value)*time.Second) return nil } func (ttlc *Controller) updateNodeIfNeeded(ctx context.Context, key string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/topology_hints.go
deviceHints[resource] = []topologymanager.TopologyHint{} continue } klog.InfoS("Regenerating TopologyHints for resource already allocated to pod", "resource", resource, "pod", klog.KObj(pod), "containerName", container.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 9.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
attribute.String("k8s.pod", klog.KObj(pod).String()), semconv.K8SPodNameKey.String(pod.Name), attribute.String("k8s.pod.update_type", updateType.String()), semconv.K8SNamespaceNameKey.String(pod.Namespace), )) klog.V(4).InfoS("SyncPod enter", "pod", klog.KObj(pod), "podUID", pod.UID) defer func() { klog.V(4).InfoS("SyncPod exit", "pod", klog.KObj(pod), "podUID", pod.UID, "isTerminal", isTerminal)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager.go
"pod", klog.KObj(pod), "containerName", c.Name) return } w := newWorker(m, startup, pod, c) m.workers[key] = w go w.run() } if c.ReadinessProbe != nil { key.probeType = readiness if _, ok := m.workers[key]; ok { klog.V(8).ErrorS(nil, "Readiness probe already exists for container", "pod", klog.KObj(pod), "containerName", c.Name) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0)