WithOnStepStart 设置步骤开始回调
(fn func(plan *ExecutionPlan, step *Step))
| 27 | |
| 28 | // WithOnStepStart 设置步骤开始回调 |
| 29 | func WithOnStepStart(fn func(plan *ExecutionPlan, step *Step)) ExecutorOption { |
| 30 | return func(e *Executor) { |
| 31 | e.onStepStart = fn |
| 32 | } |
| 33 | } |
| 34 | |
| 35 | // WithOnStepComplete 设置步骤完成回调 |
| 36 | func WithOnStepComplete(fn func(plan *ExecutionPlan, step *Step)) ExecutorOption { |
no outgoing calls