Searched refs:probeManager (Results 1 – 5 of 5) sorted by relevance
/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/prober/ |
H A D | worker.go | 60 probeManager *manager member 92 probeManager: m, 137 if probeTickerPeriod > time.Since(w.probeManager.start) { 150 w.probeManager.removeWorker(w.pod.UID, w.container.Name, w.probeType) 184 status, ok := w.probeManager.statusManager.GetPodStatus(w.pod.UID) 267 result, err := w.probeManager.prober.probe(w.probeType, w.pod, status, w.container, w.containerID)
|
H A D | worker_test.go | 321 result, ok := resultsManager(w.probeManager, w.probeType).Get(w.containerID)
|
/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/ |
H A D | kubelet.go | 766 klet.probeManager = prober.NewManager( 971 probeManager prober.Manager member 2230 kl.probeManager.AddPod(pod) 2264 kl.probeManager.RemovePod(pod)
|
H A D | kubelet_pods.go | 1082 kl.probeManager.CleanupPods(runningPods) 1434 kl.probeManager.UpdatePodStatus(pod.UID, s)
|
H A D | kubelet_test.go | 246 kubelet.probeManager = probetest.FakeManager{}
|