cmapisrv-mock: configure bootstrap QPS to speed-up initial synch

Configure by default higher rate limiter settings during the bootstrap phase, to speed it up as no watchers are active yet at that point. Signed-off-by: Marco Iorio <[email protected]>
cilium · Jul 4, 2024 · d683edd · d683edd
1 parent 40e2511
commit d683edd
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 1 deletion.
diff --git a/cmapisrv-mock/deploy/cmapisrv-mock/templates/deployment.yaml b/cmapisrv-mock/deploy/cmapisrv-mock/templates/deployment.yaml
@@ -115,6 +115,7 @@ spec:
         - --random-svc-ip6={{ .Values.config.randomSvcIP6 }}
         - --kvstore-opt=etcd.config=/var/lib/cilium/etcd-config.yaml
         - --kvstore-opt=etcd.qps={{ .Values.config.etcdQPS }}
+        - --kvstore-opt=etcd.bootstrapQps={{ .Values.config.etcdBootstrapQPS }}
         - --kvstore-opt=etcd.maxInflight={{ .Values.config.etcdMaxInflight }}
         - --prometheus-serve-addr=:9999
         ports:

diff --git a/cmapisrv-mock/deploy/cmapisrv-mock/values.yaml b/cmapisrv-mock/deploy/cmapisrv-mock/values.yaml
@@ -56,6 +56,7 @@ config:
 
   # Global etcd rate limiting settings.
   etcdQPS: 1000
+  etcdBootstrapQPS: 10000
   etcdMaxInflight: 100
 
 podAnnotations: {}

diff --git a/cmapisrv-mock/internal/mocker/cells.go b/cmapisrv-mock/internal/mocker/cells.go
@@ -30,7 +30,11 @@ var Cell = cell.Module(
 
 	kvstore.Cell(kvstore.EtcdBackendName),
 	heartbeat.Cell,
-	cell.Provide(func() *kvstore.ExtraOptions { return nil }),
+	cell.Provide(func(ss syncstate.SyncState) *kvstore.ExtraOptions {
+		return &kvstore.ExtraOptions{
+			BootstrapComplete: ss.WaitChannel(),
+		}
+	}),
 	store.Cell,
 
 	cmhealth.HealthAPIServerCell,