fix: filter invalid pod status and ip (#129)

* 过滤非Running状态

* 过滤非正常状态和ip的pod

* remove succeeded status

Co-authored-by: hexuan <hexuan@douyu.tv>
Co-authored-by: 大可 <hnlq.sysu@gmail.com>

Author: 3 people

internal/pkg/service/k8s/common.go

@@ -13,3 +13,7 @@ const (
 	podItem              = "/api/v1/namespaces/%s/pods/%s"
 	podLog               = "/api/v1/namespaces/%s/pods/%s/log"
 )
+
+var AllowPodStatus = map[string]bool{
+	"Running":   true,
+}

internal/pkg/service/k8s/pod.go

@@ -129,6 +129,14 @@ func (i *syncPod) commonCheck(in *v1.Pod) error {
 			return errors.New("exclude Suffix " + suffix)
 		}
 	}
+	// 检查状态
+	if !AllowPodStatus[string(in.Status.Phase)] {
+		return errors.New("pass status  " + string(in.Status.Phase))
+	}
+	// 检查容器ip
+	if strings.TrimSpace(in.Status.PodIP) == "" {
+		return errors.New("pass nil pod ip  ")
+	}
 	return nil
 }
 func (i *syncPod) add(obj interface{}) {
@@ -147,6 +155,7 @@ func (i *syncPod) add(obj interface{}) {
 		xlog.String("step", "add-print"),
 		xlog.String("zoneCode", i.zoneCode),
 		xlog.String("podName", in.Name),
+		xlog.String("status", string(in.Status.Phase)),
 		xlog.Any("lab", in.Labels))
 
 	err = i.mysqlCreateOrUpdate(i.zoneCode, obj.(*v1.Pod))