- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for startedStaticPodsByFullname (0.37 sec)
-
pkg/kubelet/pod_workers_test.go
} // if maps are neither nil nor empty if len(podWorkers.startedStaticPodsByFullname) != 0 || len(podWorkers.startedStaticPodsByFullname) != len(tc.expectedStartedStaticPodsByFullname) { if !reflect.DeepEqual( podWorkers.startedStaticPodsByFullname, tc.expectedStartedStaticPodsByFullname) { t.Errorf("startedStaticPodsByFullname: expected %v, got %v", tc.expectedStartedStaticPodsByFullname,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
} status.finished = true status.working = false status.terminatedAt = p.clock.Now() if p.startedStaticPodsByFullname[status.fullname] == pod.UID { delete(p.startedStaticPodsByFullname, status.fullname) } } // startPodSync is invoked by each pod worker goroutine when a message arrives on the pod update channel.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
// send a create of a static pod pod := staticPod() // block startup of the static pod due to full name collision w.startedStaticPodsByFullname[kubecontainer.GetPodFullName(pod)] = types.UID("2") w.UpdatePod(UpdatePodOptions{ UpdateType: kubetypes.SyncPodCreate, StartTime: time.Unix(1, 0).UTC(), Pod: pod, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0)