- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for syncBatch (0.4 sec)
-
pkg/kubelet/status/status_manager_test.go
t.Logf("Should not sync pod in syncBatch because there is no corresponding mirror pod for the static pod.") m.syncBatch(true) assert.Equal(t, len(m.kubeClient.(*fake.Clientset).Actions()), 0, "Expected no updates after syncBatch, got %+v", m.kubeClient.(*fake.Clientset).Actions()) t.Logf("Create the mirror pod")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
syncTicker := time.NewTicker(syncPeriod).C // syncPod and syncBatch share the same go routine to avoid sync races. go wait.Forever(func() { for { select { case <-m.podStatusChannel: klog.V(4).InfoS("Syncing updated statuses") m.syncBatch(false) case <-syncTicker: klog.V(4).InfoS("Syncing all statuses") m.syncBatch(true) } } }, 0) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0)