haozhifeng
2021-08-12 fb66c0fd0f434ea46dfb2699525d5a59b019b457
logc.go
@@ -108,6 +108,10 @@
   deliverLog(log, timeout)
}
func SaveRuleServerLog(ruleServerPushLog RuleServerPushLog, timeout time.Duration) {
   deliverLog(&ruleServerPushLog, timeout)
}
func deliverLog(l LogPrinter, timeout time.Duration) {
   select {
   case logCh <- l:
@@ -162,6 +166,7 @@
const (
   OperationLogTopic = "operationLogSaveTopic"
   ScheduleLogTopic = "scheduleLogSaveTopic"
   RuleServerLogTopic = "ruleServerLogSaveTopic"
)
func saveLoop(logCallback LogReportCallback, wg *sync.WaitGroup, done  chan struct{}) {