This commit is contained in:
Gyu-Ho Lee 2016-04-30 22:06:35 -07:00
parent 789122ecc1
commit 143bdfac72
11 changed files with 43 additions and 26 deletions

View File

@ -1,7 +1,7 @@
titles:
- Write 50K keys, 1-client, 1-conn, 64-byte key with random texts(<1MB) (etcd v3)
- Write 100K keys, 1-client, 1-conn, 64-byte key with random texts(<1MB) (etcd v3)
- Write 5K keys, 1-client, 1-conn, 32-byte key with random texts(<1MB) (etcd v3)
- Write 7K keys, 1-client, 1-conn, 32-byte key with random texts(<1MB) (etcd v3)
step1:
- data_path_list:

View File

@ -7,9 +7,9 @@ google_cloud_storage_bucket_name: dbtester-results
google_cloud_storage_sub_directory: 2016043002
peer_ips:
- 10.240.0.17
- 10.240.0.18
- 10.240.0.19
- 10.240.0.21
- 10.240.0.22
- 10.240.0.23
agent_port: 3500
database_port: 2379
@ -30,10 +30,11 @@ step2:
result_path: timeseries.csv
connections: 1
clients: 1
key_size: 64
key_size: 32
value_size: 1
value_testdata_path: /home/gyuho/testdata
total_requests: 50000
total_requests: 5000
request_interval_ms: 200
etcdv3_compaction_cycle: 0
# after benchmark

View File

@ -30,10 +30,11 @@ step2:
result_path: timeseries.csv
connections: 1
clients: 1
key_size: 64
key_size: 32
value_size: 1
value_testdata_path: /home/gyuho/testdata
total_requests: 50000
total_requests: 5000
request_interval_ms: 200
etcdv3_compaction_cycle: 0
# after benchmark

View File

@ -7,9 +7,9 @@ google_cloud_storage_bucket_name: dbtester-results
google_cloud_storage_sub_directory: 2016043002
peer_ips:
- 10.240.0.17
- 10.240.0.18
- 10.240.0.19
- 10.240.0.25
- 10.240.0.26
- 10.240.0.27
agent_port: 3500
database_port: 2379
@ -30,10 +30,11 @@ step2:
result_path: timeseries.csv
connections: 1
clients: 1
key_size: 64
key_size: 32
value_size: 1
value_testdata_path: /home/gyuho/testdata
total_requests: 50000
total_requests: 5000
request_interval_ms: 200
etcdv3_compaction_cycle: 0
# after benchmark

View File

@ -7,9 +7,9 @@ google_cloud_storage_bucket_name: dbtester-results
google_cloud_storage_sub_directory: 2016043002
peer_ips:
- 10.240.0.17
- 10.240.0.18
- 10.240.0.19
- 10.240.0.21
- 10.240.0.22
- 10.240.0.23
agent_port: 3500
database_port: 2379
@ -30,10 +30,11 @@ step2:
result_path: timeseries.csv
connections: 1
clients: 1
key_size: 64
key_size: 32
value_size: 1
value_testdata_path: /home/gyuho/testdata
total_requests: 100000
total_requests: 7000
request_interval_ms: 200
etcdv3_compaction_cycle: 0
# after benchmark

View File

@ -30,10 +30,11 @@ step2:
result_path: timeseries.csv
connections: 1
clients: 1
key_size: 64
key_size: 32
value_size: 1
value_testdata_path: /home/gyuho/testdata
total_requests: 100000
total_requests: 7000
request_interval_ms: 200
etcdv3_compaction_cycle: 0
# after benchmark

View File

@ -7,9 +7,9 @@ google_cloud_storage_bucket_name: dbtester-results
google_cloud_storage_sub_directory: 2016043002
peer_ips:
- 10.240.0.17
- 10.240.0.18
- 10.240.0.19
- 10.240.0.25
- 10.240.0.26
- 10.240.0.27
agent_port: 3500
database_port: 2379
@ -30,10 +30,11 @@ step2:
result_path: timeseries.csv
connections: 1
clients: 1
key_size: 64
key_size: 32
value_size: 1
value_testdata_path: /home/gyuho/testdata
total_requests: 100000
total_requests: 7000
request_interval_ms: 200
etcdv3_compaction_cycle: 0
# after benchmark

View File

@ -58,6 +58,7 @@ type Config struct {
ValueSize int `yaml:"value_size"`
ValueTestDataPath string `yaml:"value_testdata_path"`
TotalRequests int `yaml:"total_requests"`
RequestIntervalMs int `yaml:"request_interval_ms"`
Etcdv3CompactionCycle int `yaml:"etcdv3_compaction_cycle"`
} `yaml:"step2"`

View File

@ -84,6 +84,9 @@ func TestReadConfig(t *testing.T) {
if c.Step2.TotalRequests != 3000000 {
t.Fatalf("unexpected %d", c.Step2.TotalRequests)
}
if c.Step2.RequestIntervalMs != 100 {
t.Fatalf("unexpected %d", c.Step2.RequestIntervalMs)
}
if c.Step3.Skip {
t.Fatalf("unexpected %v", c.Step3.Skip)
}

View File

@ -309,6 +309,9 @@ func step2(cfg Config) error {
case "consul":
requests <- request{consulOp: consulOp{key: k, value: v}}
}
if cfg.Step2.RequestIntervalMs > 0 {
time.Sleep(time.Duration(cfg.Step2.RequestIntervalMs) * time.Millisecond)
}
}
close(requests)
}()
@ -499,6 +502,9 @@ func step2(cfg Config) error {
// serializable read by default
requests <- request{consulOp: consulOp{key: key}}
}
if cfg.Step2.RequestIntervalMs > 0 {
time.Sleep(time.Duration(cfg.Step2.RequestIntervalMs) * time.Millisecond)
}
}
close(requests)
}()

View File

@ -34,6 +34,7 @@ step2:
value_size: 256
value_testdata_path: /home/gyuho/testdata # overwrites value_size
total_requests: 3000000
request_interval_ms: 100
etcdv3_compaction_cycle: 0
# after benchmark