tests: make compaction period a configurable attribute.

Keep the default value to 200ms while using shorter value for regression tests that require frequent compaction.

Signed-off-by: Jiayin Mao <[email protected]>

tests/robustness/main_test.go

@@ -41,7 +41,7 @@ var testRunner = framework.E2eTestRunner
 
 var (
 	WaitBeforeFailpoint = time.Second
-	WaitJitter          = traffic.CompactionPeriod
+	WaitJitter          = traffic.DefaultCompactionPeriod
 	WaitAfterFailpoint  = time.Second
 )
 

tests/robustness/scenarios/scenarios.go

@@ -225,7 +225,7 @@ func Regression(t *testing.T) []TestScenario {
 	})
 	scenarios = append(scenarios, TestScenario{
 		Name:      "Issue18089",
-		Profile:   traffic.LowTraffic,
+		Profile:   traffic.LowTraffic.WithCompactionPeriod(100 * time.Millisecond), // Use frequent compaction for high reproduce rate
 		Failpoint: failpoint.SleepBeforeSendWatchResponse,
 		Traffic:   traffic.EtcdDelete,
 		Cluster: *e2e.NewConfig(

tests/robustness/traffic/traffic.go

@@ -33,11 +33,11 @@ import (
 )
 
 var (
-	DefaultLeaseTTL   int64 = 7200
-	RequestTimeout          = 200 * time.Millisecond
-	WatchTimeout            = time.Second
-	MultiOpTxnOpCount       = 4
-	CompactionPeriod        = 100 * time.Millisecond
+	DefaultLeaseTTL         int64 = 7200
+	RequestTimeout                = 200 * time.Millisecond
+	WatchTimeout                  = time.Second
+	MultiOpTxnOpCount             = 4
+	DefaultCompactionPeriod       = 200 * time.Millisecond
 
 	LowTraffic = Profile{
 		MinimalQPS:                     100,
@@ -96,7 +96,11 @@ func SimulateTraffic(ctx context.Context, t *testing.T, lg *zap.Logger, clus *e2
 			defer wg.Done()
 			defer c.Close()
 
-			RunCompactLoop(ctx, c, CompactionPeriod, finish)
+			compactionPeriod := DefaultCompactionPeriod
+			if profile.CompactPeriod != time.Duration(0) {
+				compactionPeriod = profile.CompactPeriod
+			}
+			RunCompactLoop(ctx, c, compactionPeriod, finish)
 			mux.Lock()
 			reports = append(reports, c.Report())
 			mux.Unlock()
@@ -176,13 +180,19 @@ type Profile struct {
 	MaxNonUniqueRequestConcurrency int
 	ClientCount                    int
 	ForbidCompaction               bool
+	CompactPeriod                  time.Duration
 }
 
 func (p Profile) WithoutCompaction() Profile {
 	p.ForbidCompaction = true
 	return p
 }
 
+func (p Profile) WithCompactionPeriod(cp time.Duration) Profile {
+	p.CompactPeriod = cp
+	return p
+}
+
 type Traffic interface {
 	Run(ctx context.Context, c *client.RecordingClient, qpsLimiter *rate.Limiter, ids identity.Provider, lm identity.LeaseIDStorage, nonUniqueWriteLimiter ConcurrencyLimiter, finish <-chan struct{})
 	ExpectUniqueRevision() bool