Commit 89913c2e by 孙龙

init

parent 8760f513
Showing with 1 additions and 1 deletions
...@@ -100,7 +100,7 @@ func InitLogSink() (err error) { ...@@ -100,7 +100,7 @@ func InitLogSink() (err error) {
// 选择db和collection // 选择db和collection
G_logSink = &LogSink{ G_logSink = &LogSink{
client: client, client: client,
logCollection: client.Database("ichunt").Collection("monitor_log"), logCollection: client.Database("monitor").Collection("monitor_log"),
logChan: make(chan *DataParams, 1000), logChan: make(chan *DataParams, 1000),
//autoCommitChan: make(chan *common.LogBatch, 1000), //autoCommitChan: make(chan *common.LogBatch, 1000),
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment