in pkg/k8s/k8s.go [73:84]
func (w *nodeWatcher) GetPods() []*v1.Pod {
if !w.PodInformer.HasSynced() {
klog.V(1).Infoln("cache for pod informer has not fully synced")
return nil
}
pods := []*v1.Pod{}
for _, p := range w.PodInformer.GetStore().List() {
p := p.(*v1.Pod)
pods = append(pods, p)
}
return pods
}