- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ComparePods (0.2 sec)
-
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) -
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) -
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)