Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 139 for KObj (0.05 sec)

  1. pkg/scheduler/framework/plugins/nodeports/node_ports.go

    		return framework.QueueSkip, nil
    	}
    
    	logger.V(4).Info("the deleted pod and the target pod have any common port(s), returning Queue as deleting this Pod may make the Pod schedulable", "pod", klog.KObj(pod), "deletedPod", klog.KObj(deletedPod))
    	return framework.Queue, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 10:53:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    	klog.V(3).InfoS("computePodActions got for pod", "podActions", podContainerChanges, "pod", klog.KObj(pod))
    	if podContainerChanges.CreateSandbox {
    		ref, err := ref.GetReference(legacyscheme.Scheme, pod)
    		if err != nil {
    			klog.ErrorS(err, "Couldn't make a ref to pod", "pod", klog.KObj(pod))
    		}
    		if podContainerChanges.SandboxID != "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  3. pkg/controller/volume/pvprotection/pv_protection_controller.go

    	logger := klog.FromContext(ctx)
    	if err != nil {
    		logger.V(3).Info("Error adding protection finalizer to PV", "PV", klog.KObj(pv), "err", err)
    		return err
    	}
    	logger.V(3).Info("Added protection finalizer to PV", "PV", klog.KObj(pv))
    	return nil
    }
    
    func (c *Controller) removeFinalizer(ctx context.Context, pv *v1.PersistentVolume) error {
    	pvClone := pv.DeepCopy()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. pkg/controller/deployment/rolling.go

    	if oldPodsCount == 0 {
    		// Can't scale down further
    		return false, nil
    	}
    	allPodsCount := deploymentutil.GetReplicaCountForReplicaSets(allRSs)
    	logger.V(4).Info("New replica set", "replicaSet", klog.KObj(newRS), "availableReplicas", newRS.Status.AvailableReplicas)
    	maxUnavailable := deploymentutil.MaxUnavailable(*deployment)
    
    	// Check if we can scale down. We can scale down in the following 2 cases:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 07:09:11 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  5. pkg/kubelet/kuberuntime/security_context_windows.go

    			"pod", klog.KObj(pod), "containerName", container.Name)
    	}
    	if effectiveSc.SELinuxOptions != nil {
    		klog.InfoS("Windows container does not support SecurityContext.SELinuxOptions, please use SecurityContext.WindowsOptions",
    			"pod", klog.KObj(pod), "containerName", container.Name)
    	}
    	if effectiveSc.RunAsGroup != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 18 22:23:13 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  6. 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)
  7. pkg/kubelet/lifecycle/handlers.go

    			klog.V(1).ErrorS(err, "Exec lifecycle hook for Container in Pod failed", "execCommand", handler.Exec.Command, "containerName", container.Name, "pod", klog.KObj(pod), "message", string(output))
    		}
    		return msg, err
    	case handler.HTTPGet != nil:
    		err := hr.runHTTPHandler(ctx, pod, container, handler, hr.eventRecorder)
    		var msg string
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 19 11:40:52 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  8. pkg/controller/deployment/rollback.go

    		if err != nil {
    			logger.V(4).Info("Unable to extract revision from deployment's replica set", "replicaSet", klog.KObj(rs), "err", err)
    			continue
    		}
    		if v == rollbackTo.Revision {
    			logger.V(4).Info("Found replica set with desired revision", "replicaSet", klog.KObj(rs), "revision", v)
    			// rollback by copying podTemplate.Spec from the replica set
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 23:39:52 UTC 2023
    - 6.7K bytes
    - Viewed (0)
  9. pkg/controller/resourceclaim/controller.go

    					err := ec.kubeClient.ResourceV1alpha2().ResourceClaims(claim.Namespace).Delete(ctx, claim.Name, metav1.DeleteOptions{})
    					if err != nil {
    						return fmt.Errorf("delete claim: %v", err)
    					}
    				} else {
    					logger.V(6).Info("wrong pod content, not deleting claim", "claim", klog.KObj(claim), "podUID", podUID, "podContent", pod)
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/nodevolumelimits/csi.go

    			return framework.Queue, nil
    		}
    	}
    
    	logger.V(5).Info("The deleted pod does not impact the scheduling of the unscheduled pod", "deletedPod", klog.KObj(pod), "pod", klog.KObj(deletedPod))
    	return framework.QueueSkip, nil
    }
    
    // PreFilter invoked at the prefilter extension point
    //
    // If the pod haven't those types of volumes, we'll skip the Filter phase
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
Back to top