OnWorkflowRegistered Workflow 注册事件
(wf workflow.Agent)
| 135 | |
| 136 | // OnWorkflowRegistered Workflow 注册事件 |
| 137 | func (i *AGUIInterface) OnWorkflowRegistered(wf workflow.Agent) error { |
| 138 | if i.opts.EnableLogging { |
| 139 | fmt.Printf(" [AGUI] Workflow registered: %s\n", wf.Name()) |
| 140 | fmt.Printf(" → Syncing to Control Plane\n") |
| 141 | } |
| 142 | |
| 143 | // 同步到控制平面 |
| 144 | return i.syncWorkflow(wf) |
| 145 | } |
| 146 | |
| 147 | // connect 连接到控制平面 |
| 148 | func (i *AGUIInterface) connect(ctx context.Context) error { |
nothing calls this directly
no test coverage detected