Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ComparePods (0.2 sec)

  1. pkg/kubelet/container/runtime_cache_test.go

    	cache.ForceUpdateIfOlder(ctx, time.Now().Add(-20*time.Minute))
    	actual := cache.GetCachedPods()
    	comparePods(t, oldpods, actual)
    
    	// A newer timestamp should force an update.
    	cache.ForceUpdateIfOlder(ctx, time.Now().Add(20*time.Second))
    	actual = cache.GetCachedPods()
    	comparePods(t, newpods, actual)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 13:02:13 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/cache/debugger/comparer.go

    	}
    
    	cached := []string{}
    	for nodeName := range nodeinfos {
    		cached = append(cached, nodeName)
    	}
    
    	return compareStrings(actual, cached)
    }
    
    // ComparePods compares actual pods with cached pods.
    func (c *CacheComparer) ComparePods(pods, waitingPods []*v1.Pod, nodeinfos map[string]*framework.NodeInfo) (missed, redundant []string) {
    	actual := []string{}
    	for _, pod := range pods {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/cache/debugger/comparer_test.go

    	for _, uid := range cached {
    		pod := &v1.Pod{}
    		pod.UID = types.UID(uid)
    		pod.Namespace = "ns"
    		pod.Name = uid
    
    		nodeInfo[uid] = framework.NewNodeInfo(pod)
    	}
    
    	m, r := compare.ComparePods(pods, queuedPods, nodeInfo)
    
    	if diff := cmp.Diff(missing, m); diff != "" {
    		t.Errorf("Unexpected missing (-want, +got):\n%s", diff)
    	}
    
    	if diff := cmp.Diff(redundant, r); diff != "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 08:00:25 UTC 2023
    - 4.8K bytes
    - Viewed (0)
Back to top