- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for PodSync (0.15 sec)
-
pkg/kubelet/pleg/generic_test.go
} } func TestRelisting(t *testing.T) { testPleg := newTestGenericPLEG() pleg, runtime := testPleg.pleg, testPleg.runtime ch := pleg.Watch() // The first relist should send a PodSync event to each pod. runtime.AllPodList = []*containertest.FakePod{ {Pod: &kubecontainer.Pod{ ID: "1234", Containers: []*kubecontainer.Container{ createTestContainer("c1", kubecontainer.ContainerStateExited),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 24.8K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
// attempted for testing. func (m *manager) syncBatch(all bool) int { type podSync struct { podUID types.UID statusUID kubetypes.MirrorPodUID status versionedPodStatus } var updatedStatuses []podSync podToMirror, mirrorToPod := m.podManager.GetUIDTranslations() func() { // Critical section m.podStatusesLock.RLock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0)