SriovOperatorConfig.LogLevel e2e tests

Signed-off-by: Andrea Panattoni <[email protected]>

controllers/sriovnetworknodepolicy_controller.go

@@ -100,6 +100,7 @@ func (r *SriovNetworkNodePolicyReconciler) Reconcile(ctx context.Context, req ct
 				reqLogger.Error(err, "Failed to create default Policy", "Namespace", namespace, "Name", constants.DefaultPolicyName)
 				return reconcile.Result{}, err
 			}
+			reqLogger.Info("Default policy created")
 			return reconcile.Result{}, nil
 		}
 		// Error reading the object - requeue the request.

test/conformance/tests/test_sriov_operator.go

@@ -28,6 +28,7 @@ import (
 	runtimeclient "sigs.k8s.io/controller-runtime/pkg/client"
 
 	sriovv1 "github.com/k8snetworkplumbingwg/sriov-network-operator/api/v1"
+	"github.com/k8snetworkplumbingwg/sriov-network-operator/pkg/consts"
 	"github.com/k8snetworkplumbingwg/sriov-network-operator/test/util/clean"
 	"github.com/k8snetworkplumbingwg/sriov-network-operator/test/util/cluster"
 	"github.com/k8snetworkplumbingwg/sriov-network-operator/test/util/discovery"
@@ -171,6 +172,63 @@ var _ = Describe("[sriov] operator", func() {
 			})
 		})
 
+		Context("LogLevel affects operator's logs", func() {
+			It("when set to 0 no lifecycle logs are present", func() {
+				initialLogLevelValue := getOperatorConfigLogLevel()
+				DeferCleanup(func() {
+					By("Restore LogLevel to its initial value")
+					setOperatorConfigLogLevel(initialLogLevelValue)
+				})
+
+				By("Set operator LogLevel to 2")
+				setOperatorConfigLogLevel(2)
+
+				since := time.Now()
+
+				By("Delete default policy to trigget some operator's activity")
+				err := clients.SriovnetworkV1Interface.SriovNetworkNodePolicies(operatorNamespace).Delete(context.Background(), consts.DefaultPolicyName, metav1.DeleteOptions{})
+				Expect(err).ToNot(HaveOccurred())
+
+				By("Assert logs contains operator activity")
+				Eventually(func(g Gomega) {
+					logs := getOperatorLogs(since)
+					g.Expect(logs).To(
+						ContainElement(
+							ContainSubstring("Default policy created"),
+						),
+					)
+
+					g.Expect(logs).To(
+						ContainElement(
+							ContainSubstring("Start to sync device plugin ConfigMap"),
+						),
+					)
+				}, 1*time.Minute, 1*time.Second).Should(Succeed())
+
+				By("Reduce operator LogLevel to 0")
+				setOperatorConfigLogLevel(0)
+
+				By("Delete default policy to trigget some operator's activity")
+				err = clients.SriovnetworkV1Interface.SriovNetworkNodePolicies(operatorNamespace).Delete(context.Background(), consts.DefaultPolicyName, metav1.DeleteOptions{})
+				Expect(err).ToNot(HaveOccurred())
+
+				By("Assert logs contains less operator activity")
+				Eventually(func(g Gomega) {
+					logs := getOperatorLogs(since)
+					g.Expect(logs).To(
+						ContainElement(
+							ContainSubstring("Default policy created"),
+						),
+					)
+
+					g.Expect(logs).ToNot(
+						ContainElement(
+							ContainSubstring("Start to sync device plugin ConfigMap"),
+						),
+					)
+				}, 1*time.Minute, 1*time.Second).Should(Succeed())
+			})
+		})
 	})
 
 	Describe("Generic SriovNetworkNodePolicy", func() {
@@ -2389,6 +2447,50 @@ func setSriovOperatorSpecFlag(flagName string, flagValue bool) {
 	}
 }
 
+func setOperatorConfigLogLevel(level int) {
+	cfg := sriovv1.SriovOperatorConfig{}
+	err := clients.Get(context.TODO(), runtimeclient.ObjectKey{
+		Name:      "default",
+		Namespace: operatorNamespace,
+	}, &cfg)
+	Expect(err).ToNot(HaveOccurred())
+
+	cfg.Spec.LogLevel = level
+	err = clients.Update(context.TODO(), &cfg)
+	Expect(err).ToNot(HaveOccurred())
+}
+
+func getOperatorConfigLogLevel() int {
+	cfg := sriovv1.SriovOperatorConfig{}
+	err := clients.Get(context.TODO(), runtimeclient.ObjectKey{
+		Name:      "default",
+		Namespace: operatorNamespace,
+	}, &cfg)
+	Expect(err).ToNot(HaveOccurred())
+
+	return cfg.Spec.LogLevel
+}
+
+func getOperatorLogs(since time.Time) []string {
+	podList, err := clients.Pods(operatorNamespace).List(context.Background(), metav1.ListOptions{
+		LabelSelector: "name=sriov-network-operator",
+	})
+	ExpectWithOffset(1, err).ToNot(HaveOccurred())
+	ExpectWithOffset(1, podList.Items).To(HaveLen(1), "One operator pod expected")
+
+	pod := podList.Items[0]
+	logStart := metav1.NewTime(since)
+	rawLogs, err := clients.Pods(pod.Namespace).
+		GetLogs(pod.Name, &corev1.PodLogOptions{
+			Container: pod.Spec.Containers[0].Name,
+			SinceTime: &logStart,
+		}).
+		DoRaw(context.Background())
+	ExpectWithOffset(1, err).ToNot(HaveOccurred())
+
+	return strings.Split(string(rawLogs), "\n")
+}
+
 func assertObjectIsNotFound(name string, obj runtimeclient.Object) {
 	Eventually(func() bool {
 		err := clients.Get(context.Background(), runtimeclient.ObjectKey{Name: name, Namespace: operatorNamespace}, obj)