Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for KObj (0.05 sec)

  1. pkg/scheduler/framework/plugins/noderesources/fit.go

    			logger.V(5).Info("the deleted pod was unscheduled and it wouldn't make the unscheduled pod schedulable", "pod", klog.KObj(pod), "deletedPod", klog.KObj(originalPod))
    			return framework.QueueSkip, nil
    		}
    		logger.V(5).Info("another scheduled pod was deleted, and it may make the unscheduled pod schedulable", "pod", klog.KObj(pod), "deletedPod", klog.KObj(originalPod))
    		return framework.Queue, nil
    	}
    
    	if !f.enableInPlacePodVerticalScaling {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  2. pkg/scheduler/schedule_one.go

    	// When contextualized logging hits GA
    	// https://github.com/kubernetes/kubernetes/issues/111672
    	logger = klog.LoggerWithValues(logger, "pod", klog.KObj(pod))
    	ctx = klog.NewContext(ctx, logger)
    	logger.V(4).Info("About to try and schedule pod", "pod", klog.KObj(pod))
    
    	fwk, err := sched.frameworkForPod(pod)
    	if err != nil {
    		// This shouldn't happen, because we only accept for scheduling the pods
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue.go

    				if asErr != nil {
    					logger.Error(err, "QueueingHintFn returns error", "event", event, "plugin", hintfn.PluginName, "pod", klog.KObj(pod))
    				} else {
    					logger.Error(err, "QueueingHintFn returns error", "event", event, "plugin", hintfn.PluginName, "pod", klog.KObj(pod), "oldObj", klog.KObj(oldObjMeta), "newObj", klog.KObj(newObjMeta))
    				}
    				hint = framework.Queue
    			}
    			if hint == framework.QueueSkip {
    				continue
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  4. 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)
  5. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go

    		return framework.Queue, nil
    	}
    
    	logger.V(5).Info("node was created or updated, but it doesn't change the TaintToleration plugin's decision", "pod", klog.KObj(pod), "node", klog.KObj(modifiedNode))
    	return framework.QueueSkip, nil
    }
    
    // Filter invoked at the filter extension point.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  6. 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)
  7. pkg/kubelet/kubelet_node_status.go

    			klog.ErrorS(err, "Unable to construct v1.Node object for kubelet")
    			continue
    		}
    
    		klog.InfoS("Attempting to register node", "node", klog.KObj(node))
    		registered := kl.tryRegisterWithAPIServer(node)
    		if registered {
    			klog.InfoS("Successfully registered node", "node", klog.KObj(node))
    			kl.registrationCompleted = true
    			return
    		}
    	}
    }
    
    // tryRegisterWithAPIServer makes an attempt to register the given node with
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  8. pkg/kubelet/kuberuntime/kuberuntime_container.go

    		klog.V(2).InfoS("PreStop hook not completed in grace period", "pod", klog.KObj(pod), "podUID", pod.UID,
    			"containerName", containerSpec.Name, "containerID", containerID.String(), "gracePeriod", gracePeriod)
    	case <-done:
    		klog.V(3).InfoS("PreStop hook completed", "pod", klog.KObj(pod), "podUID", pod.UID,
    			"containerName", containerSpec.Name, "containerID", containerID.String())
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  9. pkg/kubelet/volumemanager/volume_manager.go

    			err)
    	}
    
    	klog.V(3).InfoS("All volumes are attached and mounted for pod", "pod", klog.KObj(pod))
    	return nil
    }
    
    func (vm *volumeManager) WaitForUnmount(ctx context.Context, pod *v1.Pod) error {
    	if pod == nil {
    		return nil
    	}
    
    	klog.V(3).InfoS("Waiting for volumes to unmount for pod", "pod", klog.KObj(pod))
    	uniquePodName := util.GetUniquePodName(pod)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet_pods.go

    			continue
    		}
    		secret, err := kl.secretManager.GetSecret(pod.Namespace, secretRef.Name)
    		if err != nil {
    			klog.InfoS("Unable to retrieve pull secret, the image pull may not succeed.", "pod", klog.KObj(pod), "secret", klog.KObj(secret), "err", err)
    			failedPullSecrets = append(failedPullSecrets, secretRef.Name)
    			continue
    		}
    
    		pullSecrets = append(pullSecrets, *secret)
    	}
    
    	if len(failedPullSecrets) > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top