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{}) {