runner

Documentation

Index

• Constants
• Variables
• type Config
  • func DefaultConfig() *Config
• type File
• type Metadata
• type Output
• type Proto
• type Result
• type Runner
  • func New(_ context.Context, cfg *Config) Runner
• type Spec
• type Task
• type Timeout

Constants

const (
	LIVELOG = 5000
	TIME    = 12
	UNIT    = "hour"
)

Variables

var (
	UnitMap = map[string]time.Duration{
		"second": time.Second,
		"minute": time.Minute,
		"hour":   time.Hour,
	}
)

Types

type Config

type Config struct {
	Config config.Config
	Dag    dag.DAG
	Data   Proto
}

func DefaultConfig

func DefaultConfig() *Config

type File

type File struct {
	Content string `json:"content"`
	Gzip    bool   `json:"gzip"`
}

type Metadata

type Metadata struct {
	Name string `json:"name"`
}

type Output

type Output struct {
	Pos     int64  `json:"pos"`
	Time    int64  `json:"time"`
	Message string `json:"message"`
}

type Proto

type Proto struct {
	ApiVersion string   `json:"apiVersion"`
	Kind       string   `json:"kind"`
	Metadata   Metadata `json:"metadata"`
	Spec       Spec     `json:"spec"`
}

type Result

type Result struct {
	Output Output `json:"output"`
	Error  string `json:"error"`
}

type Runner

type Runner interface {
	Init(context.Context) error
	Deinit(context.Context) error
	Run(context.Context) error
	Tail(ctx context.Context) dagRunner.Livelog
	Tasks(ctx context.Context) []Task
}

func New

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

type Spec

type Spec struct {
	Tasks []Task `json:"tasks"`
}

type Task

type Task struct {
	Name     string   `json:"name"`
	File     File     `json:"file"`
	Commands []string `json:"commands"`
	Livelog  int64    `json:"livelog"`
	Timeout  Timeout  `json:"timeout"`
	Depends  []string `json:"depends"`
}

type Timeout

type Timeout struct {
	Time int64  `json:"time"`
	Unit string `json:"unit"`
}