Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for comparePods (0.15 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

    }
    
    // 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 {
    		actual = append(actual, string(pod.UID))
    	}
    
    	cached := []string{}
    	for _, nodeinfo := range nodeinfos {
    		for _, p := range nodeinfo.Pods {
    			cached = append(cached, string(p.Pod.UID))
    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)
  4. pkg/registry/core/node/strategy_test.go

    		node        *api.Node
    		oldNode     *api.Node
    		compareNode *api.Node
    	}{
    		{
    			name:        "nil pod cidrs",
    			node:        makeNode(nil, false, false),
    			oldNode:     nil,
    			compareNode: makeNode(nil, false, false),
    		},
    		{
    			name:        "empty pod ips",
    			node:        makeNode([]string{}, false, false),
    			oldNode:     nil,
    			compareNode: makeNode([]string{}, false, false),
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:48:03 UTC 2023
    - 9.7K bytes
    - Viewed (0)
  5. pilot/pkg/config/monitor/monitor.go

    		log.Warnf("Failed to delete config (%+v): %v ", *c, err)
    	}
    }
    
    // compareIDs compares the IDs (i.e. Namespace, GroupVersionKind, and Name) of the two configs and returns
    // 0 if a == b, -1 if a < b, and 1 if a > b. Used for sorting config arrays.
    func compareIDs(a, b *config.Config) int {
    	return strings.Compare(a.Key(), b.Key())
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Feb 12 17:36:33 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  6. src/cmd/vendor/github.com/google/pprof/internal/graph/graph.go

    				if iv, jv := l.Info.PrintableName(), r.Info.PrintableName(); iv != jv {
    					return iv < jv
    				}
    				return compareNodes(l, r)
    			},
    		}
    	case NameOrder:
    		s = nodeSorter{ns,
    			func(l, r *Node) bool {
    				if iv, jv := l.Info.Name, r.Info.Name; iv != jv {
    					return iv < jv
    				}
    				return compareNodes(l, r)
    			},
    		}
    	case FileOrder:
    		s = nodeSorter{ns,
    			func(l, r *Node) bool {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 31K bytes
    - Viewed (0)
  7. pilot/pkg/config/monitor/file_snapshot.go

    type byKey []*config.Config
    
    func (rs byKey) Len() int {
    	return len(rs)
    }
    
    func (rs byKey) Swap(i, j int) {
    	rs[i], rs[j] = rs[j], rs[i]
    }
    
    func (rs byKey) Less(i, j int) bool {
    	return compareIDs(rs[i], rs[j]) < 0
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Feb 12 17:36:33 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/resolve/ResolveTestFixture.groovy

                    variants: variants,
                    ignoreReasons: baseNode.ignoreReasons,
                    ignoreReasonPrefixes: baseNode.ignoreReasonPrefixes)
            }
            compareNodes("components in graph", parseNodes(actualComponents), expectedComponents)
    
            def actualEdges = findLines(configDetails, 'dependency')
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 37.8K bytes
    - Viewed (0)
Back to top