workflow

type Callback interface {
	Trigger(ctx context.Context, task Task)
}

type Dag struct {
	Vertexes []*Vertex
	// contains filtered or unexported fields
}

type DelayTask struct {
	Delay time.Duration
	Task
}

type Executor interface {
	Execute(ctx context.Context, task Task) error
}

type FuncExecutor func(ctx context.Context, task Task) error

type NoneNotify struct {
}

type Notifier interface {
	Event(ctx context.Context, format string, v ...interface{})
	Notify(ctx context.Context, name string, progress float32)
}

type Policy uint8

type RetryOption func(*retryOption)

type State string

type Storage interface {
}

type Task interface {
	ID() string
	Name() string
	State() (State, error)
	Description() string
	CreateTime() time.Time
	UpdateTime() time.Time
	Meta() map[string]interface{}

	Commit(ctx context.Context, opts ...TaskOption) error
	Rollback(ctx context.Context, opts ...TaskOption) error
}

type TaskOption func(*taskOption)

type Vertex struct {
	Task Task
	//Condition Condition
	Prev []*Vertex
	Next []*Vertex
}