func()

in pkg/k8s/k8s.go [136:147]


func (w *clusterWatcher) GetDaemonSets() []*appsv1.DaemonSet {
	if !w.DaemonSetInformer.HasSynced() {
		klog.V(1).Infoln("cache for Daemonsets informer has not fully synced")
		return nil
	}
	daemonSets := []*appsv1.DaemonSet{}
	for _, d := range w.DaemonSetInformer.GetStore().List() {
		d := d.(*appsv1.DaemonSet)
		daemonSets = append(daemonSets, d)
	}
	return daemonSets
}