applyInboundNode 在后台异步将指定节点的最新配置下发到节点(inbound 变更后调用)。
(nodeID string)
| 275 | |
| 276 | // applyInboundNode 在后台异步将指定节点的最新配置下发到节点(inbound 变更后调用)。 |
| 277 | func (a *inboundAPI) applyInboundNode(nodeID string) { |
| 278 | go func() { |
| 279 | ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) |
| 280 | defer cancel() |
| 281 | if err := jobs.ApplyNode(ctx, nodeID, a.nodeStore, a.userStore, a.store, a.outboundStore, a.dial, a.applyOpts); err != nil { |
| 282 | log.Printf("warn: apply node %s after inbound change: %v", nodeID, err) |
| 283 | } |
| 284 | }() |
| 285 | } |
| 286 | |
| 287 | func writeInboundError(w http.ResponseWriter, err error) { |
| 288 | status := http.StatusInternalServerError |
no test coverage detected