runner

type Cache[K comparable, V any] interface {
	Load(K) (V, bool)
	Store(K, V)
	Delete(K)
	Reset()
	Range(func(K, V) bool)
	Len() int
}

type FuncOption interface {
	String() string
	Execute(Task) error
}

type FuncOptionCreator func() FuncOption

type FuncOptionWithArg[T any] interface {
	String() string
	Execute(Task, T) error
}

type Logger interface {
	Info(...interface{})
	Infof(string, ...interface{})
	Error(...interface{})
	Errorf(string, ...interface{})
}

type Option interface {
	NewTask() Task
}

type Runner interface {
	Context() context.Context
	Execute(Task)
	Submit(string, func(Task) error, ...taskOption) Task
	SubmitByOption(FuncOption, ...taskOption) Task
	SubmitByTask(Task) Task
	Get(string) (Task, bool)
	GetAll(...func(Task) bool) []Task
	Retry(string) error
	RetryAll(...func(Task) bool)
	Cancel(string) error
	CancelAll(...func(Task) bool)
	Remove(string) error
	RemoveAll(...func(Task) bool)
}

type State int32

type Task interface {
	Id() string
	Name() string
	Err() error
	Log() string
	State() State
	Progress() float64
	ProgressState() string
	Children() []Task
	StartTime() time.Time
	EndTime() time.Time
	DryRun() bool

	Done() <-chan struct{}
	Reset(context.Context)
	Running() bool
	Context() context.Context
	Logger() Logger
	Run()
	Cancel()
	SetName(string)
	SetState(State)
	SetProgress(float64)
	SetProgressState(string)
}

type TaskFilterFunc func(Task) bool