Change limiter of cr-syncer to ItemFastSlowRateLimieter

oliver-goetz · Jan 28, 2021 · a9def91 · a9def91
1 parent 6990b46
commit a9def91
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/go/cmd/cr-syncer/syncer.go b/src/go/cmd/cr-syncer/syncer.go
@@ -20,6 +20,7 @@ import (
 	"log"
 	"net/http"
 	"strconv"
+	"time"
 
 	"go.opencensus.io/stats"
 	"go.opencensus.io/stats/view"
@@ -171,8 +172,8 @@ func newCRSyncer(
 		subtree:         annotations[annotationStatusSubtree],
 		upstream:        remote.Resource(gvr).Namespace(ns),
 		downstream:      local.Resource(gvr).Namespace(ns),
-		upstreamQueue:   workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "upstream"),
-		downstreamQueue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "downstream"),
+		upstreamQueue:   workqueue.NewNamedRateLimitingQueue(workqueue.NewItemFastSlowRateLimiter(time.Millisecond*500, time.Second*5, 5), "upstream"),
+		downstreamQueue: workqueue.NewNamedRateLimitingQueue(workqueue.NewItemFastSlowRateLimiter(time.Millisecond*500, time.Second*5, 5), "downstream"),
 		done:            make(chan struct{}),
 	}
 	switch src := annotations[annotationSpecSource]; src {