获取应用的Pod增加存储字段

internal/logic/getapppodsbyappnamelogic.go

@@ -32,24 +32,37 @@ func (l *GetAppPodsByAppNameLogic) GetAppPodsByAppName(in *kubernetes.AppDetailR
 	details := make([]*kubernetes.PodDetail, 0)
 	//查询指定集群下指定命名空间下和名字的deployment详情
 	for k, _ := range pkg.KClients {
+		appDetail := kubernetes.PodDetail{
+			ClusterName: k,
+		}
+		storeAmount := 0
 		appSelector := fmt.Sprintf("app=%s", in.Name)
-		KPodList := []*kubernetes.Pod{}
+		var KPodList []*kubernetes.Pod
 		//查询pods
 		pods, err := pkg.KClients[k].ClientSet.CoreV1().Pods(in.Namespace).List(context.Background(), metav1.ListOptions{LabelSelector: appSelector})
 		if err != nil {
 			return &kubernetes.PodDetailResp{
-				Code: "200",
+				Code: "500",
 				Msg:  err.Error(),
 			}, err
 		}
+		//查询指定集群下指定命名空间下和名字的statefulSets详情
+		statefulSets, _ := pkg.KClients[k].ClientSet.AppsV1().StatefulSets(in.Namespace).Get(context.Background(), in.Name, metav1.GetOptions{})
+		//计算存储卷大小
+		if statefulSets.Spec.VolumeClaimTemplates != nil {
+			//存储卷大小求和
+			for k := range statefulSets.Spec.VolumeClaimTemplates {
+				storeAmount += int(statefulSets.Spec.VolumeClaimTemplates[k].Spec.Resources.Requests.Storage().Value())
+			}
+			storeAmount = storeAmount / 1024 / 1024 / 1024
+			appDetail.StoreAmount = int64(storeAmount)
+		}
+
 		if len(pods.Items) > 0 {
 			tool.Convert(pods.Items, &KPodList)
-			appDetail := kubernetes.PodDetail{
+			appDetail.Items = KPodList
-				ClusterName: k,
-				Items:       KPodList,
-			}
-			details = append(details, &appDetail)
 		}
+		details = append(details, &appDetail)
 	}
 
 	return &kubernetes.PodDetailResp{

pb/kubernetes.proto

@@ -143,7 +143,8 @@ message AppDetail {
 
 message PodDetail {
   string clusterName = 1; //集群名称
-  repeated Pod podList = 2; //pod列表
+  repeated Pod items = 2; //pod列表
+  int64  storeAmount = 3; //存储总量，单位使用Gi
 }
 
 message PodDetailResp {