revert using ratelimiting on queue adds

pluralsh · Oct 31, 2023 · 6fb84b8 · 6fb84b8
1 parent 4f5edf6
commit 6fb84b8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/agent/agent.go b/pkg/agent/agent.go
@@ -106,7 +106,7 @@ func (agent *Agent) Run() {
 
 		for _, svc := range svcs {
 			log.Info("sending update for", "service", svc.ID)
-			agent.svcQueue.AddRateLimited(svc.ID)
+			agent.svcQueue.Add(svc.ID)
 		}
 
 		info, err := agent.discoveryClient.ServerVersion()