dag

Documentation

Index

• Constants
• type ActionResult
• type DAG
  • func (d *DAG) AddTask(name string, task, rollback func(context.Context, io.Writer) error, ...) error
  • func (d DAG) Check() error
  • func (d DAG) Do(ctx context.Context, out io.Writer) error
• type Task
  • func (n Task) Rollback(ctx context.Context, out io.Writer) error
  • func (n Task) Run(ctx context.Context, out io.Writer) error
• type TaskErrors
  • func (d TaskErrors) Error() string

Constants

const ResultChanLength = 10

Types

type ActionResult

type ActionResult struct {
	Name string
	Err  error
}

type DAG

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

func (*DAG) AddTask

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

func (DAG) Check

func (d DAG) Check() error

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

func (DAG) Do

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

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

type Task

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

func (Task) Rollback

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

func (Task) Run

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

type TaskErrors

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

func (TaskErrors) Error

func (d TaskErrors) Error() string