modify queue size

This commit is contained in:
Ulric Qin 2022-04-14 17:19:14 +08:00
parent 08141e36cb
commit 1633308000
2 changed files with 2 additions and 2 deletions

View File

@ -181,7 +181,7 @@ MaxIdleConnsPerHost = 10
[WriterOpt] [WriterOpt]
# queue max size # queue max size
QueueMaxSize = 10000000 QueueMaxSize = 100000
# once pop samples number from queue # once pop samples number from queue
QueuePopSize = 2000 QueuePopSize = 2000
# unit: ms # unit: ms

View File

@ -102,7 +102,7 @@ func MustLoad(fpaths ...string) {
} }
if C.WriterOpt.QueueMaxSize <= 0 { if C.WriterOpt.QueueMaxSize <= 0 {
C.WriterOpt.QueueMaxSize = 10000000 C.WriterOpt.QueueMaxSize = 100000
} }
if C.WriterOpt.QueuePopSize <= 0 { if C.WriterOpt.QueuePopSize <= 0 {