From 844c4b02f73518e4aaa267bb3e497fc2cc273506 Mon Sep 17 00:00:00 2001 From: Wei Fu Date: Wed, 24 Apr 2024 11:00:07 +0800 Subject: [PATCH] tests/e2e: support CompactionBatchLimit flag Signed-off-by: Wei Fu --- tests/e2e/cluster_test.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/tests/e2e/cluster_test.go b/tests/e2e/cluster_test.go index 982eb3a82..97cae3898 100644 --- a/tests/e2e/cluster_test.go +++ b/tests/e2e/cluster_test.go @@ -140,6 +140,7 @@ type etcdProcessClusterConfig struct { MaxConcurrentStreams uint32 // default is math.MaxUint32 WatchProcessNotifyInterval time.Duration + CompactionBatchLimit int debug bool @@ -333,6 +334,9 @@ func (cfg *etcdProcessClusterConfig) etcdServerProcessConfigs() []*etcdServerPro if cfg.WatchProcessNotifyInterval != 0 { args = append(args, "--experimental-watch-progress-notify-interval", cfg.WatchProcessNotifyInterval.String()) } + if cfg.CompactionBatchLimit != 0 { + args = append(args, "--experimental-compaction-batch-limit", fmt.Sprintf("%d", cfg.CompactionBatchLimit)) + } if cfg.debug { args = append(args, "--debug")