tickerInfo 上报到elasticsearch
This commit is contained in:
parent
7925a0168b
commit
e50d818d9b
@ -87,7 +87,7 @@ func WriteLogProcess(cr *Core) {
|
||||
for {
|
||||
wg := <-cr.WriteLogChan
|
||||
go func(wg *WriteLog) {
|
||||
fmt.Println("start writelog: " + wg.Id)
|
||||
fmt.Println("start writelog: " + wg.Tag + " " + wg.Id)
|
||||
wg.Process(cr)
|
||||
}(wg)
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user