tests: Allow configuring progress notify interval in e2e tests

Signed-off-by: Marek Siarkowicz <siarkowicz@google.com>
etcd-io · Mar 14, 2023 · 9886141 · 9886141
1 parent 6ddb23c
commit 9886141
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/tests/e2e/cluster_test.go b/tests/e2e/cluster_test.go
@@ -177,10 +177,11 @@ type etcdProcessClusterConfig struct {
 	rollingStart bool
 	logLevel     string
 
-	MaxConcurrentStreams    uint32 // default is math.MaxUint32
-	CorruptCheckTime        time.Duration
-	CompactHashCheckEnabled bool
-	CompactHashCheckTime    time.Duration
+	MaxConcurrentStreams       uint32 // default is math.MaxUint32
+	CorruptCheckTime           time.Duration
+	CompactHashCheckEnabled    bool
+	CompactHashCheckTime       time.Duration
+	WatchProcessNotifyInterval time.Duration
 }
 
 // newEtcdProcessCluster launches a new cluster from etcd processes, returning
@@ -338,6 +339,9 @@ func (cfg *etcdProcessClusterConfig) etcdServerProcessConfigs(tb testing.TB) []*
 		if cfg.CompactHashCheckTime != 0 {
 			args = append(args, "--experimental-compact-hash-check-time", cfg.CompactHashCheckTime.String())
 		}
+		if cfg.WatchProcessNotifyInterval != 0 {
+			args = append(args, "--experimental-watch-progress-notify-interval", cfg.WatchProcessNotifyInterval.String())
+		}
 
 		etcdCfgs[i] = &etcdServerProcessConfig{
 			lg:           lg,