Fix bug causing excessive event sending of workload events.

Signed-off-by: Thomas Hallgren <thomas@tada.se>
telepresenceio · Oct 30, 2024 · 5596c91 · 5596c91
1 parent 5872772
commit 5596c91
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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) {