Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 139 for KObj (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top