WithOnStepFailed 设置步骤失败回调
(fn func(plan *ExecutionPlan, step *Step, err error))
| 41 | |
| 42 | // WithOnStepFailed 设置步骤失败回调 |
| 43 | func WithOnStepFailed(fn func(plan *ExecutionPlan, step *Step, err error)) ExecutorOption { |
| 44 | return func(e *Executor) { |
| 45 | e.onStepFailed = fn |
| 46 | } |
| 47 | } |
| 48 | |
| 49 | // WithOnPlanComplete 设置计划完成回调 |
| 50 | func WithOnPlanComplete(fn func(plan *ExecutionPlan)) ExecutorOption { |
no outgoing calls