[horus] Add fetch pod (#380)
fix typo
diff --git a/app/horus/core/horuser/pod_remove.go b/app/horus/core/horuser/pod_remove.go
index 7a7a5c5..89984fe 100644
--- a/app/horus/core/horuser/pod_remove.go
+++ b/app/horus/core/horuser/pod_remove.go
@@ -66,3 +66,21 @@
}
return true
}
+
+func (h *Horuser) Fetch(clusterName, podNamespace, fieldSelector string) ([]corev1.Pod, error) {
+ kubeClient := h.kubeClientMap[clusterName]
+ if kubeClient == nil {
+ klog.Errorf("Fetch kubeClient by clusterName empty.")
+ klog.Infof("clusterName:%v", clusterName)
+ return nil, nil
+ }
+ ctx, cancel := h.GetK8sContext()
+ defer cancel()
+ list := v1.ListOptions{FieldSelector: fieldSelector}
+ pods, err := kubeClient.CoreV1().Pods(podNamespace).List(ctx, list)
+ if err != nil {
+ klog.Errorf("Fetch list pod err:%v", err)
+ klog.Infof("clusterName:%v fieldSelector:%v", clusterName, fieldSelector)
+ }
+ return pods.Items, err
+}
