| | |
|---|
| | | package logc |
|---|
| | | |
|---|
| | | import ( |
|---|
| | | "basic.com/valib/bhomebus.git" |
|---|
| | | "basic.com/valib/bhshmq.git/proto/source/bhome_msg" |
|---|
| | | "fmt" |
|---|
| | | "sync" |
|---|
| | |
|---|
| | | deliverLog(log, timeout) |
|---|
| | | } |
|---|
| | | |
|---|
| | | func SaveRuleServerLog(ruleServerPushLog RuleServerPushLog, timeout time.Duration) { |
|---|
| | | deliverLog(&ruleServerPushLog, timeout) |
|---|
| | | } |
|---|
| | | |
|---|
| | | func deliverLog(l LogPrinter, timeout time.Duration) { |
|---|
| | | select { |
|---|
| | | case logCh <- l: |
|---|
| | |
|---|
| | | const ( |
|---|
| | | OperationLogTopic = "operationLogSaveTopic" |
|---|
| | | ScheduleLogTopic = "scheduleLogSaveTopic" |
|---|
| | | RuleServerLogTopic = "ruleServerLogSaveTopic" |
|---|
| | | ) |
|---|
| | | |
|---|
| | | func saveLoop(logCallback LogReportCallback, wg *sync.WaitGroup, done chan struct{}) { |
|---|
