fix KubeletSummaryClient

kubewharf · Feb 28, 2024 · b24c422 · b24c422
1 parent 8b6d6ab
commit b24c422
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/pkg/metaserver/agent/metric/provisioner/kubelet/client/client.go b/pkg/metaserver/agent/metric/provisioner/kubelet/client/client.go
@@ -47,7 +47,7 @@ func (c *KubeletSummaryClient) Summary(ctx context.Context) (*statsapi.Summary,
 			return nil, fmt.Errorf("failed to get kubelet config for summary api, error: %v", err)
 		}
 	} else {
-		url := fmt.Sprintf(summaryApi, c.baseConf.KubeletReadOnlyPort, c.baseConf.KubeletPodsEndpoint)
+		url := fmt.Sprintf(summaryApi, c.baseConf.KubeletReadOnlyPort, c.baseConf.KubeletSummaryEndpoint)
 		if err := process.GetAndUnmarshal(url, summary); err != nil {
 			return nil, fmt.Errorf("failed to get summary, error: %v", err)
 		}

diff --git a/pkg/util/process/http.go b/pkg/util/process/http.go
@@ -314,6 +314,10 @@ func GetAndUnmarshal(url string, v interface{}) error {
 		return err
 	}
 
+	if resp.StatusCode != http.StatusOK {
+		return fmt.Errorf("invalid response status code %d, url: %s", resp.StatusCode, url)
+	}
+
 	err = json.Unmarshal(body, v)
 	if err != nil {
 		return err