Automation of OCP-55033

Author: asahay19

test/extended/node/OWNERS

@@ -0,0 +1,12 @@
+reviewers:
+  - lyman9966
+  - asahay19
+  - cpmeadors
+  - sairameshv
+  - mrunalp
+  - BhargaviGudi
+approvers:
+  - lyman9966
+  - cpmeadors
+  - sairameshv
+  - mrunalp

test/extended/node/node.go

@@ -0,0 +1,19 @@
+package node
+
+import (
+	g "github.com/onsi/ginkgo/v2"
+	exutil "github.com/openshift/origin/test/extended/util"
+	//e2e "k8s.io/kubernetes/test/e2e/framework"
+)
+
+var _ = g.Describe("[sig-node] NODE initContainer policy,volume,readines,quota", func() {
+	var (
+		oc = exutil.NewCLIWithoutNamespace("node").AsAdmin()
+	)
+
+	//author: asahay@redhat.com
+	g.It("check KUBELET_LOG_LEVEL is 2", func() {
+		g.By("check Kubelet Log Level\n")
+		assertKubeletLogLevel(oc)
+	})
+})

test/extended/node/node_utils.go

@@ -0,0 +1,61 @@
+package node
+
+import (
+	"fmt"
+	"strings"
+	"time"
+
+	o "github.com/onsi/gomega"
+	exutil "github.com/openshift/origin/test/extended/util"
+	compat_otp "github.com/openshift/origin/test/extended/util/compat_otp"
+	"k8s.io/apimachinery/pkg/util/wait"
+	e2e "k8s.io/kubernetes/test/e2e/framework"
+)
+
+func assertKubeletLogLevel(oc *exutil.CLI) {
+	var kubeservice string
+	var kublet string
+	var err error
+	waitErr := wait.Poll(10*time.Second, 1*time.Minute, func() (bool, error) {
+		nodeName, nodeErr := oc.AsAdmin().WithoutNamespace().Run("get").Args("nodes", "-o=jsonpath={.items[*].metadata.name}").Output()
+		o.Expect(nodeErr).NotTo(o.HaveOccurred())
+		e2e.Logf("\nNode Names are %v", nodeName)
+		nodes := strings.Fields(nodeName)
+
+		for _, node := range nodes {
+			nodeStatus, statusErr := oc.AsAdmin().WithoutNamespace().Run("get").Args("nodes", node, "-o=jsonpath={.status.conditions[?(@.type=='Ready')].status}").Output()
+			o.Expect(statusErr).NotTo(o.HaveOccurred())
+			e2e.Logf("\nNode %s Status is %s\n", node, nodeStatus)
+
+			if nodeStatus == "True" {
+				kubeservice, err = compat_otp.DebugNodeWithChroot(oc, node, "/bin/bash", "-c", "systemctl show kubelet.service | grep KUBELET_LOG_LEVEL")
+				o.Expect(err).NotTo(o.HaveOccurred())
+				kublet, err = compat_otp.DebugNodeWithChroot(oc, node, "/bin/bash", "-c", "ps aux | grep kubelet")
+				o.Expect(err).NotTo(o.HaveOccurred())
+
+				if strings.Contains(string(kubeservice), "KUBELET_LOG_LEVEL") && strings.Contains(string(kublet), "--v=2") {
+					e2e.Logf(" KUBELET_LOG_LEVEL is 2. \n")
+					return true, nil
+				} else {
+					e2e.Logf(" KUBELET_LOG_LEVEL is not 2. \n")
+					return false, nil
+				}
+			} else {
+				e2e.Logf("\n NODES ARE NOT READY\n ")
+			}
+		}
+		return false, nil
+	})
+	if waitErr != nil {
+		e2e.Logf("Kubelet Log level is:\n %v\n", kubeservice)
+		e2e.Logf("Running Proccess of kubelet are:\n %v\n", kublet)
+		AssertWaitPollNoErr(waitErr, "KUBELET_LOG_LEVEL is not expected")
+	}
+}
+
+func AssertWaitPollNoErr(err error, desc string) {
+	if err == nil {
+		return
+	}
+	panic(fmt.Sprintf("Timed out waiting for %q: %v", desc, err))
+}