Added healthcheck changes

Signed-off-by: Patryk Strusiewicz-Surmacki <[email protected]>

pkg/healthcheck/healthcheck.go

@@ -163,6 +163,15 @@ func (hc *HealthChecker) CheckReachability() error {
 	return nil
 }
 
+// CheckAPIServer checks if Kubernetes API Server is reachable.
+func (hc *HealthChecker) CheckAPIServer(ctx context.Context) error {
+	pods := &corev1.PodList{}
+	if err := hc.client.List(ctx, pods); err != nil {
+		return fmt.Errorf("error listing pods: %w", err)
+	}
+	return nil
+}
+
 func (hc *HealthChecker) checkReachabilityItem(r netReachabilityItem) error {
 	target := r.Host + ":" + strconv.Itoa(r.Port)
 	conn, err := hc.toolkit.tcpDialer.Dial("tcp", target)

pkg/healthcheck/healthcheck_test.go

@@ -262,6 +262,16 @@ var _ = Describe("HealthCheck", func() {
 			Expect(err).To(HaveOccurred())
 		})
 	})
+	Context("CheckAPIServer() should", func() {
+		It("return no error", func() {
+			c := fake.NewClientBuilder().Build()
+			hc, err := NewHealthChecker(c, NewHealthCheckToolkit(nil, nil, nil), &NetHealthcheckConfig{})
+			Expect(err).ToNot(HaveOccurred())
+			Expect(hc).ToNot(BeNil())
+			err = hc.CheckAPIServer(context.TODO())
+			Expect(err).ToNot(HaveOccurred())
+		})
+	})
 })
 
 func fakeErrorGetByName(_ string) (netlink.Link, error) {