Add note about buffer time and change example_2

pull/4168/head
Michael Desa 2015-09-25 16:41:25 -07:00
parent 8a76e7db78
commit 293fad1e20
2 changed files with 6 additions and 3 deletions

View File

@ -1,15 +1,15 @@
channel_buffer_size = 50000
channel_buffer_size = 100000
[write]
concurrency = 10
batch_size = 5000
batch_size = 10000
batch_interval = "0s"
database = "stress"
precision = "n"
address = "localhost:8086"
reset_database = true
# doesnt do anything
starting_point = 0 # how far back in time to go in weeks
starting_point = 4 # how far back in time to go in weeks
[[series]]
point_count = 50 # number of points that will be written for each of the series

View File

@ -205,7 +205,10 @@ func Run(cfg *Config, done chan struct{}, ts chan time.Time) (totalPoints int, f
}()
fmt.Println("Filling the Point Channel Buffer...")
fmt.Printf("Test will begin in %v seconds\n", (time.Duration(cfg.ChannelBufferSize/10) * time.Millisecond).Seconds())
time.Sleep(time.Duration(cfg.ChannelBufferSize/10) * time.Millisecond)
fmt.Println("Starting Stress...")
timer = NewTimer()