From 5596c914425204c6461c91cc940ca6187274236d Mon Sep 17 00:00:00 2001 From: Thomas Hallgren Date: Tue, 29 Oct 2024 17:10:29 +0100 Subject: [PATCH] Fix bug causing excessive event sending of workload events. Signed-off-by: Thomas Hallgren --- cmd/traffic/cmd/manager/state/workload_info_watcher.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/cmd/traffic/cmd/manager/state/workload_info_watcher.go b/cmd/traffic/cmd/manager/state/workload_info_watcher.go index beb7b85134..3db126e817 100644 --- a/cmd/traffic/cmd/manager/state/workload_info_watcher.go +++ b/cmd/traffic/cmd/manager/state/workload_info_watcher.go @@ -197,7 +197,6 @@ func rpcWorkload(wl k8sapi.Workload, as rpc.WorkloadInfo_AgentState, iClients [] } func (wf *workloadInfoWatcher) addEvent( - ctx context.Context, eventType workload.EventType, wl k8sapi.Workload, as rpc.WorkloadInfo_AgentState, @@ -207,7 +206,7 @@ func (wf *workloadInfoWatcher) addEvent( Type: rpc.WorkloadEvent_Type(eventType), Workload: rpcWorkload(wl, as, iClients), } - wf.sendEvents(ctx, false) + wf.resetTicker() } func (wf *workloadInfoWatcher) handleWorkloadsSnapshot(ctx context.Context, wes []workload.WorkloadEvent, initial bool) {