Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 139 for KObj (0.03 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/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)
  3. 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)
  4. 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)
  5. pkg/kubelet/runonce.go

    			klog.InfoS("Pod's containers running", "pod", klog.KObj(pod))
    			return nil
    		}
    		klog.InfoS("Pod's containers not running: syncing", "pod", klog.KObj(pod))
    
    		klog.InfoS("Creating a mirror pod for static pod", "pod", klog.KObj(pod))
    		if err := kl.mirrorPodClient.CreateMirrorPod(pod); err != nil {
    			klog.ErrorS(err, "Failed creating a mirror pod", "pod", klog.KObj(pod))
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 04 06:56:50 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/scheduler/internal/cache/node_tree.go

    			if nodeName == n.Name {
    				logger.Info("Did not add to the NodeTree because it already exists", "node", klog.KObj(n))
    				return
    			}
    		}
    		nt.tree[zone] = append(na, n.Name)
    	} else {
    		nt.zones = append(nt.zones, zone)
    		nt.tree[zone] = []string{n.Name}
    	}
    	logger.V(2).Info("Added node in listed group to NodeTree", "node", klog.KObj(n), "zone", zone)
    	nt.numNodes++
    }
    
    // removeNode removes a node from the NodeTree.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/memorymanager/fake_memory_manager.go

    }
    
    func (m *fakeManager) Allocate(pod *v1.Pod, container *v1.Container) error {
    	klog.InfoS("Allocate", "pod", klog.KObj(pod), "containerName", container.Name)
    	return nil
    }
    
    func (m *fakeManager) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) {
    	klog.InfoS("Add container", "pod", klog.KObj(pod), "containerName", container.Name, "containerID", containerID)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 3.1K bytes
    - Viewed (0)
Back to top