taskflow

type GraphConfig struct {
	FinishStepKey string

	StartStyleColor   string
	FinishStyleColor  string
	RunStepStyleColor string
}

type RunStep struct {
	StepKey  string
	StepCode string
}

type Runner[T pcontext.Context] struct {
	GraphConfig *GraphConfig
	// contains filtered or unexported fields
}

type StepConfig[T pcontext.Context] struct {
	RetryCnt   int
	RetryDelay time.Duration

	StepFunc       StepFunc[T]
	StepFailedFunc StepFailedFunc
	RouteMap       map[string]string
}

type StepFailedFunc func(stepKey string, err error)

type StepFunc[T pcontext.Context] func(ctx T) (code string, err error)

type Task[T pcontext.Context] interface {
	Name() string

	Init(in, out interface{}) error

	StepConfigMap() map[string]*StepConfig[T]
	FirstStepKey() string

	BeforeStep(stepKey string)
	AfterStep(stepKey string)

	Error() error
}