@@ -33,7 +33,6 @@ import (
33
33
"go.etcd.io/etcd/tests/v3/framework/e2e"
34
34
"go.etcd.io/etcd/tests/v3/robustness/client"
35
35
"go.etcd.io/etcd/tests/v3/robustness/identity"
36
- "go.etcd.io/etcd/tests/v3/robustness/model"
37
36
robustnessrand "go.etcd.io/etcd/tests/v3/robustness/random"
38
37
"go.etcd.io/etcd/tests/v3/robustness/report"
39
38
"go.etcd.io/etcd/tests/v3/robustness/scenarios"
@@ -49,12 +48,6 @@ var profile = traffic.Profile{
49
48
MaxNonUniqueRequestConcurrency : 3 ,
50
49
}
51
50
52
- var (
53
- WaitBeforeFailpoint = time .Second
54
- WaitJitter = traffic .DefaultCompactionPeriod
55
- WaitAfterFailpoint = time .Second
56
- )
57
-
58
51
func main () {
59
52
ctx := context .Background ()
60
53
baseTime := time .Now ()
@@ -104,23 +97,6 @@ func validateReport(ctx context.Context, lg *zap.Logger, c *e2e.EtcdProcessClust
104
97
r .Visualize = validate .ValidateAndReturnVisualize (t , lg , validateConfig , r .Client , persistedRequests , 5 * time .Minute ).Visualize
105
98
}
106
99
107
- func randomizeTime (base time.Duration , jitter time.Duration ) time.Duration {
108
- return base - jitter + time .Duration (rand .Int63n (int64 (jitter )* 2 ))
109
- }
110
-
111
- func operationsMaxRevision (reports []report.ClientReport ) int64 {
112
- var maxRevision int64
113
- for _ , r := range reports {
114
- for _ , op := range r .KeyValue {
115
- resp := op .Output .(model.MaybeEtcdResponse )
116
- if resp .Revision > maxRevision {
117
- maxRevision = resp .Revision
118
- }
119
- }
120
- }
121
- return maxRevision
122
- }
123
-
124
100
func connect (endpoint string , ids identity.Provider , baseTime time.Time ) * client.RecordingClient {
125
101
cli , err := client .NewRecordingClient ([]string {endpoint }, ids , baseTime )
126
102
if err != nil {
0 commit comments