处理配置变化
(message *pb.NodeStreamMessage)
| 328 | |
| 329 | // 处理配置变化 |
| 330 | func (this *APIStream) handleNewNodeTask(message *pb.NodeStreamMessage) error { |
| 331 | select { |
| 332 | case nodeTaskNotify <- true: |
| 333 | default: |
| 334 | |
| 335 | } |
| 336 | this.replyOk(message.RequestId, "ok") |
| 337 | return nil |
| 338 | } |
| 339 | |
| 340 | // 检查Systemd服务 |
| 341 | func (this *APIStream) handleCheckSystemdService(message *pb.NodeStreamMessage) error { |