Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. pkg/controller/daemon/daemon_controller.go

    				podsToDelete = append(podsToDelete, oldestOldPod.Name)
    			case podutil.IsPodAvailable(oldestNewPod, ds.Spec.MinReadySeconds, metav1.Time{Time: dsc.failedPodsBackoff.Clock.Now()}):
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K 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/framework/plugins/dynamicresources/dynamicresources.go

    				}
    				if !suitable {
    					return statusUnschedulable(logger, "resourceclaim cannot be allocated for the node (unsuitable)", "pod", klog.KObj(pod), "node", klog.KObj(node), "resourceclaim", klog.KObj(claim))
    				}
    			} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/controller/daemon/update.go

    					oldPodsToDelete = append(oldPodsToDelete, oldPod.Name)
    					continue
    				}
    				// the old pod isn't available, allow it to become a replacement
    				logger.V(5).Info("Pod on node is out of date and not available, allowing replacement", "daemonset", klog.KObj(ds), "pod", klog.KObj(oldPod), "node", klog.KRef("", nodeName))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 13 16:53:53 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  10. pkg/controller/cronjob/cronjob_controllerv2.go

    	}
    
    	if jobAlreadyExists {
    		logger.Info("Job already exists", "cronjob", klog.KObj(cronJob), "job", klog.KObj(jobReq))
    	} else {
    		metrics.CronJobCreationSkew.Observe(jobResp.ObjectMeta.GetCreationTimestamp().Sub(*scheduledTime).Seconds())
    		logger.V(4).Info("Created Job", "job", klog.KObj(jobResp), "cronjob", klog.KObj(cronJob))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
Back to top