From 2a392bf8fcb68c075cc6eaaa3f9a155ed2f03b8b Mon Sep 17 00:00:00 2001 From: Amim Knabben Date: Wed, 1 Jul 2020 13:28:39 -0400 Subject: [PATCH] Fetching kubelet address:port from kubelet configuration --- test/e2e_node/util.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/test/e2e_node/util.go b/test/e2e_node/util.go index 1fca7d24f95..0beac34ecda 100644 --- a/test/e2e_node/util.go +++ b/test/e2e_node/util.go @@ -58,9 +58,6 @@ import ( "github.com/onsi/gomega" ) -// TODO(random-liu): Get this automatically from kubelet flag. -var kubeletAddress = flag.String("kubelet-address", "http://127.0.0.1:10255", "Host and port of the kubelet") - var startServices = flag.Bool("start-services", true, "If true, start local node services") var stopServices = flag.Bool("stop-services", true, "If true, stop local node services after running tests") var busyboxImage = imageutils.GetE2EImage(imageutils.BusyBox) @@ -75,7 +72,11 @@ const ( ) func getNodeSummary() (*kubeletstatsv1alpha1.Summary, error) { - req, err := http.NewRequest("GET", *kubeletAddress+"/stats/summary", nil) + kubeletConfig, err := getCurrentKubeletConfig() + if err != nil { + return nil, fmt.Errorf("failed to get current kubelet config") + } + req, err := http.NewRequest("GET", fmt.Sprintf("http://%s:%d/stats/summary", kubeletConfig.Address, kubeletConfig.ReadOnlyPort), nil) if err != nil { return nil, fmt.Errorf("failed to build http request: %v", err) }