dag

package

v0.2.134 Latest Latest Go to latest Published: Dec 25, 2019 License: BSD-2-Clause Imports: 6 Imported by: 0

Details

View Source

const ResultChanLength = 10

This section is empty.

This section is empty.

type ActionResult struct {
	Name string
	Err  error
}

type DAG struct {
	Tasks map[string]*Task `yaml:"tasks"`
}

func (d *DAG) AddTask(name string, task, rollback func(context.Context, io.Writer) error, dependsOn []string) error

func (d DAG) Check() error

topological sort 実際遅いけどもういいや O(E^2 + V)

func (d DAG) Do(ctx context.Context, out io.Writer) error

出力で時間を出したほうがよさそう

type Task struct {
	DependsOn []string `yaml:"depends_on"`
	// contains filtered or unexported fields
}

func (n Task) Rollback(ctx context.Context, out io.Writer) error

func (n Task) Run(ctx context.Context, out io.Writer) error

type TaskErrors struct {
	RunErrors      map[string]error
	RollbackErrors map[string]error
}

func (d TaskErrors) Error() string