refactor: adjust the sliding timer of Gateway (#576)

refactor: adjust the sliding timer Signed-off-by: Lin Yang <[email protected]>
flomesh-io · Dec 26, 2024 · 66c38c3 · 66c38c3
1 parent 8514ebe
commit 66c38c3
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/pkg/gateway/repo/broadcast.go b/pkg/gateway/repo/broadcast.go
@@ -13,8 +13,8 @@ func (s *Server) BroadcastListener() {
 	gatewayUpdateChan := gatewayUpdatePubSub.Sub(announcements.GatewayUpdate.String())
 	defer s.msgBroker.Unsub(gatewayUpdatePubSub, gatewayUpdateChan)
 
-	// Wait for two informer synchronization periods
-	slidingTimer := time.NewTimer(time.Second * 20)
+	// Wait for one informer synchronization periods
+	slidingTimer := time.NewTimer(time.Second * 10)
 	defer slidingTimer.Stop()
 
 	reconfirm := true
@@ -23,11 +23,10 @@ func (s *Server) BroadcastListener() {
 		select {
 		case <-gatewayUpdateChan:
 			// Wait for an informer synchronization period
-			slidingTimer.Reset(time.Second * 5)
+			slidingTimer.Reset(time.Second * 10)
 			// Avoid data omission
 			reconfirm = true
 		case <-slidingTimer.C:
-			//metricsstore.DefaultMetricsStore.ProxyConnectCount.Set(float64(len(proxies)))
 			newJob := func() *GatewayConfGeneratorJob {
 				return &GatewayConfGeneratorJob{
 					processor: s.processor,