Function WithOnStepComplete

pkg/executionplan/executor.go:36–40

WithOnStepComplete 设置步骤完成回调

(fn func(plan *ExecutionPlan, step *Step))

// WithOnStepComplete 设置步骤完成回调
func WithOnStepComplete(fn func(plan *ExecutionPlan, step *Step)) ExecutorOption {
	return func(e *Executor) {
		e.onStepComplete = fn
	}
}

// WithOnStepFailed 设置步骤失败回调
func WithOnStepFailed(fn func(plan *ExecutionPlan, step *Step, err error)) ExecutorOption {