Start 启动队列
()
| 41 | |
| 42 | // Start 启动队列 |
| 43 | func (this *ValueQueue) Start() { |
| 44 | // 这里单次循环就行，因为Loop里已经使用了Range通道 |
| 45 | err := this.Loop() |
| 46 | if err != nil { |
| 47 | remotelogs.ErrorObject("MONITOR_QUEUE", err) |
| 48 | } |
| 49 | } |
| 50 | |
| 51 | // Add 添加数据 |
| 52 | func (this *ValueQueue) Add(item string, value maps.Map) { |
nothing calls this directly
no test coverage detected