runner

Documentation

Index

• Constants
• Variables
• type Glance
• type GlanceAllocatable
• type GlanceCPU
• type GlanceDirRep
• type GlanceDirReq
• type GlanceEntry
• type GlanceFileRep
• type GlanceFileReq
• type GlanceMemory
• type GlanceReply
• type GlanceRequested
• type GlanceResource
• type GlanceStats
• type GlanceStorage
• type GlanceSysRep
• type GlanceSysReq
• type GlanceTimeout
• type Glancer
  • func GlancerNew(_ context.Context, cfg *GlancerConfig) Glancer
• type GlancerConfig
  • func GlancerDefaultConfig() *GlancerConfig
• type Metadata
• type Proto
• type Spec
• type Task
• type TaskFile
• type TaskOutput
• type TaskParam
• type TaskResult
• type TaskTimeout
• type Tasker
  • func TaskerNew(_ context.Context, cfg *TaskerConfig) Tasker
• type TaskerConfig
  • func TaskerDefaultConfig() *TaskerConfig

Constants

const (
	Livelog = 5000
	Time    = 12
	Unit    = "hour"
)

Variables

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

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

Types

type Glance

type Glance struct {
	Dir     GlanceDirReq  `json:"dir"`
	File    GlanceFileReq `json:"file"`
	Sys     GlanceSysReq  `json:"sys"`
	Timeout GlanceTimeout `json:"timeout"`
}

type GlanceAllocatable

type GlanceAllocatable struct {
	MilliCPU int64 `json:"milliCPU"`
	Memory   int64 `json:"memory"`
	Storage  int64 `json:"storage"`
}

type GlanceCPU

type GlanceCPU struct {
	Total string `json:"total"`
	Used  string `json:"used"`
}

type GlanceDirRep

type GlanceDirRep struct {
	Entries []GlanceEntry `json:"entries"`
}

type GlanceDirReq

type GlanceDirReq struct {
	Path string `json:"path"`
}

type GlanceEntry

type GlanceEntry struct {
	Name  string `json:"name"`
	IsDir bool   `json:"isDir"`
	Size  int64  `json:"size"`
	Time  string `json:"time"`
	User  string `json:"user"`
	Group string `json:"group"`
	Mode  string `json:"mode"`
}

type GlanceFileRep

type GlanceFileRep struct {
	Content  string `json:"content"`
	Readable bool   `json:"readable"`
}

type GlanceFileReq

type GlanceFileReq struct {
	Path    string `json:"path"`
	MaxSize int64  `json:"maxSize"`
}

type GlanceMemory

type GlanceMemory struct {
	Total string `json:"total"`
	Used  string `json:"used"`
}

type GlanceReply

type GlanceReply struct {
	Dir   GlanceDirRep  `json:"dir"`
	File  GlanceFileRep `json:"file"`
	Sys   GlanceSysRep  `json:"sys"`
	Error string        `json:"error"`
}

type GlanceRequested

type GlanceRequested struct {
	MilliCPU int64 `json:"milliCPU"`
	Memory   int64 `json:"memory"`
	Storage  int64 `json:"storage"`
}

type GlanceResource

type GlanceResource struct {
	Allocatable GlanceAllocatable `json:"allocatable"`
	Requested   GlanceRequested   `json:"requested"`
}

type GlanceStats

type GlanceStats struct {
	CPU     GlanceCPU     `json:"cpu"`
	Host    string        `json:"host"`
	Memory  GlanceMemory  `json:"memory"`
	OS      string        `json:"os"`
	Storage GlanceStorage `json:"storage"`
}

type GlanceStorage

type GlanceStorage struct {
	Total string `json:"total"`
	Used  string `json:"used"`
}

type GlanceSysRep

type GlanceSysRep struct {
	Resource GlanceResource `json:"resource"`
	Stats    GlanceStats    `json:"stats"`
}

type GlanceSysReq

type GlanceSysReq struct {
	Enable bool `json:"enable"`
}

type GlanceTimeout

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

type Glancer

type Glancer interface {
	Init(context.Context) error
	Deinit(context.Context) error
	Run(context.Context) (GlanceReply, error)
}

func GlancerNew

func GlancerNew(_ context.Context, cfg *GlancerConfig) Glancer

type GlancerConfig

type GlancerConfig struct {
	Config config.Config
	Data   Proto
}

func GlancerDefaultConfig

func GlancerDefaultConfig() *GlancerConfig

type Metadata

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

type Proto

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

type Spec

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

type Task

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

type TaskFile

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

type TaskOutput

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

type TaskParam

type TaskParam struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type TaskResult

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

type TaskTimeout

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

type Tasker

type Tasker 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 TaskerNew

func TaskerNew(_ context.Context, cfg *TaskerConfig) Tasker

type TaskerConfig

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

func TaskerDefaultConfig

func TaskerDefaultConfig() *TaskerConfig