notifyWorkflowRegistered 通知所有 Interfaces Workflow 已注册
(wf workflow.Agent)
| 347 | |
| 348 | // notifyWorkflowRegistered 通知所有 Interfaces Workflow 已注册 |
| 349 | func (os *AsterOS) notifyWorkflowRegistered(wf workflow.Agent) { |
| 350 | os.ifMu.RLock() |
| 351 | defer os.ifMu.RUnlock() |
| 352 | |
| 353 | for _, iface := range os.interfaces { |
| 354 | if err := iface.OnWorkflowRegistered(wf); err != nil { |
| 355 | fmt.Printf("Warning: interface %s OnWorkflowRegistered: %v\n", iface.Name(), err) |
| 356 | } |
| 357 | } |
| 358 | } |
| 359 | |
| 360 | // corsMiddleware CORS 中间件 |
| 361 | func corsMiddleware() gin.HandlerFunc { |
no test coverage detected