From c0e422d8843a9230c672165bc079b773a3433a82 Mon Sep 17 00:00:00 2001 From: Vadim Rutkovsky Date: Mon, 27 Jan 2025 16:20:36 +0100 Subject: [PATCH] debug etcdloganalyzer --- pkg/monitortestlibrary/podaccess/pod_logs_stream_all.go | 2 ++ pkg/monitortests/etcd/etcdloganalyzer/monitortest.go | 2 ++ 2 files changed, 4 insertions(+) diff --git a/pkg/monitortestlibrary/podaccess/pod_logs_stream_all.go b/pkg/monitortestlibrary/podaccess/pod_logs_stream_all.go index 46d5877740f3..053cc8b6ee44 100644 --- a/pkg/monitortestlibrary/podaccess/pod_logs_stream_all.go +++ b/pkg/monitortestlibrary/podaccess/pod_logs_stream_all.go @@ -98,6 +98,7 @@ func (c *PodsStreamer) Stop(ctx context.Context) { func (c *PodsStreamer) syncPods(ctx context.Context) error { pods, err := c.podLister.Pods(c.namespaceName).List(c.selector) if err != nil { + c.logger.WithField("error", err).WithField("namespace", c.namespaceName).Info("error listing pods") return err } @@ -106,6 +107,7 @@ func (c *PodsStreamer) syncPods(ctx context.Context) error { pod := pods[i] // skip pods that are not on nodes if len(pod.Spec.NodeName) == 0 { + c.logger.WithField("pod", pod.Name).WithField("namespace", c.namespaceName).Info("pod not on node") continue } diff --git a/pkg/monitortests/etcd/etcdloganalyzer/monitortest.go b/pkg/monitortests/etcd/etcdloganalyzer/monitortest.go index 0c9459b21d76..3a598522c28f 100644 --- a/pkg/monitortests/etcd/etcdloganalyzer/monitortest.go +++ b/pkg/monitortests/etcd/etcdloganalyzer/monitortest.go @@ -20,6 +20,7 @@ import ( "github.com/openshift/origin/pkg/monitortestframework" "github.com/openshift/origin/pkg/monitortestlibrary/podaccess" "github.com/openshift/origin/pkg/test/ginkgo/junitapi" + "github.com/sirupsen/logrus" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" ) @@ -61,6 +62,7 @@ func (w *etcdLogAnalyzer) StartCollection(ctx context.Context, adminRESTConfig * logToIntervalConverter, namespaceScopedCoreInformers.Pods(), ) + logrus.Infof("Starting informers") go kubeInformers.Start(ctx.Done()) go podStreamer.Run(ctx, w.finishedCollecting)