Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 83 for KObj (0.89 sec)

  1. pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

    				"pod", klog.KObj(pod), "createdPod", klog.KObj(modifiedPod))
    			return framework.Queue, nil
    		}
    		logger.V(5).Info("a scheduled pod was created, but it doesn't matches with the pod's topology spread constraints",
    			"pod", klog.KObj(pod), "createdPod", klog.KObj(modifiedPod))
    		return framework.QueueSkip, nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/interpodaffinity/plugin.go

    				"pod", klog.KObj(pod), "modifiedPod", klog.KObj(modifiedPod))
    			return framework.Queue, nil
    		}
    		logger.V(5).Info("a scheduled pod was added and it doesn't match the target pod's affinity",
    			"pod", klog.KObj(pod), "modifiedPod", klog.KObj(modifiedPod))
    		return framework.QueueSkip, nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumebinding/binder.go

    		newPV, err := b.kubeClient.CoreV1().PersistentVolumes().Update(ctx, binding.pv, metav1.UpdateOptions{})
    		if err != nil {
    			logger.V(4).Info("Updating PersistentVolume: binding to claim failed", "pod", klog.KObj(pod), "PV", klog.KObj(binding.pv), "PVC", klog.KObj(binding.pvc), "err", err)
    			return err
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 14:55:34 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  4. pkg/scheduler/eventhandlers.go

    	logger.V(3).Info("Delete event for node", "node", klog.KObj(node))
    	if err := sched.Cache.RemoveNode(logger, node); err != nil {
    		logger.Error(err, "Scheduler cache RemoveNode failed")
    	}
    }
    
    func (sched *Scheduler) addPodToSchedulingQueue(obj interface{}) {
    	logger := sched.logger
    	pod := obj.(*v1.Pod)
    	logger.V(3).Info("Add event for unscheduled pod", "pod", klog.KObj(pod))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
  5. pkg/scheduler/internal/cache/cache.go

    			continue
    		}
    		if cache.ttl != 0 && now.After(*ps.deadline) {
    			logger.Info("Pod expired", "podKey", key, "pod", klog.KObj(ps.pod))
    			if err := cache.removePod(logger, ps.pod); err != nil {
    				logger.Error(err, "ExpirePod failed", "podKey", key, "pod", klog.KObj(ps.pod))
    			}
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 09:56:48 UTC 2023
    - 24.9K bytes
    - Viewed (0)
  6. pkg/kubelet/volumemanager/reconciler/reconciler_common.go

    	}
    	if err == nil {
    		if remountingLogStr == "" {
    			klog.V(1).InfoS(volumeToMount.GenerateMsgDetailed("operationExecutor.MountVolume started", remountingLogStr), "pod", klog.KObj(volumeToMount.Pod))
    		} else {
    			klog.V(5).InfoS(volumeToMount.GenerateMsgDetailed("operationExecutor.MountVolume started", remountingLogStr), "pod", klog.KObj(volumeToMount.Pod))
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:23:12 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  7. 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)
  8. pkg/controller/statefulset/stateful_set_control.go

    			"statefulSet", klog.KObj(set), "pod", klog.KObj(firstUnhealthyPod))
    		return true, nil
    	}
    
    	logger.V(2).Info("Pod of StatefulSet is terminating for scale down",
    		"statefulSet", klog.KObj(set), "pod", klog.KObj(condemned[i]))
    	return true, ssc.podControl.DeleteStatefulPod(set, condemned[i])
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:03:46 UTC 2024
    - 30.9K bytes
    - Viewed (0)
  9. pkg/controller/deployment/deployment_controller.go

    	d := obj.(*apps.Deployment)
    	logger.V(4).Info("Adding deployment", "deployment", klog.KObj(d))
    	dc.enqueueDeployment(d)
    }
    
    func (dc *DeploymentController) updateDeployment(logger klog.Logger, old, cur interface{}) {
    	oldD := old.(*apps.Deployment)
    	curD := cur.(*apps.Deployment)
    	logger.V(4).Info("Updating deployment", "deployment", klog.KObj(oldD))
    	dc.enqueueDeployment(curD)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  10. pkg/controller/nodeipam/ipam/sync/sync.go

    		return err
    	}
    
    	if err := sync.kubeAPI.UpdateNodePodCIDR(ctx, node, aliasRange); err != nil {
    		logger.Error(err, "Could not update node PodCIDR", "node", klog.KObj(node), "podCIDR", aliasRange)
    		return err
    	}
    
    	logger.V(2).Info("Node PodCIDR updated", "node", klog.KObj(node), "podCIDR", aliasRange)
    
    	if err := sync.kubeAPI.UpdateNodeNetworkUnavailable(node.Name, false); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 07:50:01 UTC 2023
    - 12.6K bytes
    - Viewed (0)
Back to top