(ctx context.Context, event *WorkflowEvent)
| 123 | // EventBus 事件总线接口 |
| 124 | type EventBus interface { |
| 125 | Publish(ctx context.Context, event *WorkflowEvent) error |
| 126 | Subscribe(eventType string, handler EventHandler) error |
| 127 | Unsubscribe(eventType string, handler EventHandler) error |
| 128 | } |
no outgoing calls
no test coverage detected