- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for extractedReadinessHandling (0.15 sec)
-
pkg/kubelet/prober/prober_manager_test.go
m := newTestManager() defer cleanup(t, m) // Start syncing readiness without leaking goroutine. stopCh := make(chan struct{}) go wait.Until(m.extractedReadinessHandling, 0, stopCh) defer func() { close(stopCh) // Send an update to exit extractedReadinessHandling() m.readinessManager.Set(kubecontainer.ContainerID{}, results.Success, &v1.Pod{}) }() exec := syncExecProber{} exec.set(probe.Success, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 18.8K bytes - Viewed (0)