From 98861410f32126ee2e51f1b5f140913b5e0fc81d Mon Sep 17 00:00:00 2001 From: Marek Siarkowicz Date: Thu, 2 Feb 2023 11:37:54 +0100 Subject: [PATCH] tests: Allow configuring progress notify interval in e2e tests Signed-off-by: Marek Siarkowicz --- tests/e2e/cluster_test.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/tests/e2e/cluster_test.go b/tests/e2e/cluster_test.go index 0f8359ed4..c86a974ea 100644 --- 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,