func()

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
}