Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 139 for KObj (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/kubelet/kuberuntime/util/util.go

    		klog.V(2).InfoS("Multiple sandboxes are ready for Pod. Need to reconcile them", "pod", klog.KObj(pod))
    		return true, sandboxStatus.Metadata.Attempt + 1, sandboxStatus.Id
    	}
    	if sandboxStatus.State != runtimeapi.PodSandboxState_SANDBOX_READY {
    		klog.V(2).InfoS("No ready sandbox for pod can be found. Need to start a new one", "pod", klog.KObj(pod))
    		return true, sandboxStatus.Metadata.Attempt + 1, sandboxStatus.Id
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:14:48 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/controller/volume/pvcprotection/pvc_protection_controller.go

    	logger := klog.FromContext(ctx)
    	if err != nil {
    		logger.Error(err, "Error adding protection finalizer to PVC", "PVC", klog.KObj(pvc))
    		return err
    	}
    	logger.V(3).Info("Added protection finalizer to PVC", "PVC", klog.KObj(pvc))
    	return nil
    }
    
    func (c *Controller) removeFinalizer(ctx context.Context, pvc *v1.PersistentVolumeClaim) error {
    	claimClone := pvc.DeepCopy()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 14K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/topologymanager/scope_container.go

    		klog.InfoS("Best TopologyHint", "bestHint", bestHint, "pod", klog.KObj(pod), "containerName", container.Name)
    
    		if !admit {
    			metrics.TopologyManagerAdmissionErrorsTotal.Inc()
    			return admission.GetPodAdmitResult(&TopologyAffinityError{})
    		}
    		klog.InfoS("Topology Affinity", "bestHint", bestHint, "pod", klog.KObj(pod), "containerName", container.Name)
    		s.setTopologyHints(string(pod.UID), container.Name, bestHint)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 14:44:24 UTC 2023
    - 2.9K bytes
    - Viewed (0)
Back to top