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
}