dag

Documentation

Index

• type Config
  • func DefaultConfig() *Config
• type DAG
  • func New(_ context.Context, cfg *Config) DAG
• type Dag
• type Edge
• type Task
• type Vertex

Types

type Config

type Config struct {
	Config config.Config
}

func DefaultConfig

func DefaultConfig() *Config

type DAG

type DAG interface {
	Init(context.Context, []Task) error
	Deinit(context.Context) error
	Run(context.Context, func(string, runner.File, []runner.Param, []string, int64, runner.Language, runner.Log) error, runner.Log) error
}

func New

func New(_ context.Context, cfg *Config) DAG

type Dag

type Dag struct {
	Vertex []Vertex
	Edge   []Edge
}

type Edge

type Edge struct {
	From string
	To   string
}

type Task

type Task struct {
	Name     string
	File     runner.File
	Params   []runner.Param
	Commands []string
	Width    int64
	Language runner.Language
	Depends  []string
}

type Vertex

type Vertex struct {
	Name     string
	File     runner.File
	Params   []runner.Param
	Commands []string
	Width    int64
	Language runner.Language
}