diff --git a/.gitignore b/.gitignore index 8e8825e..0478c94 100644 --- a/.gitignore +++ b/.gitignore @@ -1,3 +1,4 @@ +.direnv .vscode /vendor kubefetch diff --git a/kubefetch.go b/kubefetch.go index 8e4b077..ddac93e 100755 --- a/kubefetch.go +++ b/kubefetch.go @@ -208,17 +208,19 @@ func getStorage(clientset *kubernetes.Clientset) string { func getKubernetesEndpointPort(clientset *kubernetes.Clientset) int { - endpoint, err := clientset.CoreV1().Endpoints("default").Get(context.TODO(), "kubernetes", v1.GetOptions{}) + endpointSlices, err := clientset.DiscoveryV1().EndpointSlices("default").List(context.TODO(), v1.ListOptions{ + LabelSelector: "kubernetes.io/service-name=kubernetes", + }) if err != nil { panic(err.Error()) } var portNumber int // Accessing the ports exposed by the Endpoint - for _, subset := range endpoint.Subsets { - for _, port := range subset.Ports { + for _, endpointSlice := range endpointSlices.Items { + for _, port := range endpointSlice.Ports { // Accessing port.Port - portNumber = int(port.Port) + portNumber = int(*port.Port) } }