events: log event kind being processed and disable resyncs (#4231)

Logs event kind being processed by the message broker and disabled the k8s period resyncs. The contoller reuses Ticker for resyncs if necessary. Signed-off-by: Shashank Ram <[email protected]>
openservicemesh · Oct 8, 2021 · 09f4838 · 09f4838
1 parent 9572b52
commit 09f4838
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/pkg/k8s/types.go b/pkg/k8s/types.go
@@ -42,7 +42,9 @@ const (
 
 const (
 	// DefaultKubeEventResyncInterval is the default resync interval for k8s events
-	DefaultKubeEventResyncInterval = 5 * time.Minute
+	// This is set to 0 because we do not need resyncs from k8s client, and have our
+	// own Ticker to turn on periodic resyncs.
+	DefaultKubeEventResyncInterval = 0 * time.Second
 )
 
 // InformerKey stores the different Informers we keep for K8s resources

diff --git a/pkg/messaging/broker.go b/pkg/messaging/broker.go
@@ -68,8 +68,10 @@ func (b *Broker) run(stopCh <-chan struct{}) {
 // 2. Processes other internal control plane events
 // 3. Updates metrics associated with the event
 func (b *Broker) processEvent(msg events.PubSubMessage) {
+	log.Trace().Msgf("Processing msg kind: %s", msg.Kind)
 	// Update proxies if applicable
 	if shouldUpdateProxy(msg) {
+		log.Trace().Msgf("Msg kind %s will update proxies", msg.Kind)
 		b.proxyUpdatePubSub.Pub(msg, announcements.ProxyUpdate.String())
 		metricsstore.DefaultMetricsStore.ProxyBroadcastEventCount.Inc()
 	}