runner

Documentation

Index

• Constants
• type Glance
• type GlanceAllocatable
• type GlanceCPU
• type GlanceDirRep
• type GlanceDirReq
• type GlanceEntry
• type GlanceFileRep
• type GlanceFileReq
• type GlanceMemory
• type GlanceProcess
• type GlanceReply
• type GlanceRequested
• type GlanceResource
• type GlanceStats
• type GlanceStorage
• type GlanceSysRep
• type GlanceSysReq
• type GlanceThread
• type Glancer
  • func GlancerNew(_ context.Context, cfg *GlancerConfig) Glancer
• type GlancerConfig
  • func GlancerDefaultConfig() *GlancerConfig
• type Maint
• type MaintClockDiff
• type MaintClockRep
• type MaintClockReq
• type MaintClockSync
• type MaintReply
• type Mainter
  • func MainterNew(_ context.Context, cfg *MainterConfig) Mainter
• type MainterConfig
  • func MainterDefaultConfig() *MainterConfig
• type Metadata
• type Proto
• type Spec
• type Task
• type TaskFile
• type TaskLog
• type TaskOutput
• type TaskParam
• type TaskResult
• type Tasker
  • func TaskerNew(_ context.Context, cfg *TaskerConfig) Tasker
• type TaskerConfig
  • func TaskerDefaultConfig() *TaskerConfig

Constants

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

Types

type Glance

type Glance struct {
	Dir     GlanceDirReq  `json:"dir"`
	File    GlanceFileReq `json:"file"`
	Sys     GlanceSysReq  `json:"sys"`
	Timeout string        `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 GlanceProcess

type GlanceProcess struct {
	Process GlanceThread   `json:"process"`
	Threads []GlanceThread `json:"threads"`
}

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"`
	Processes []GlanceProcess `json:"processes"`
}

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 GlanceThread

type GlanceThread struct {
	Name    string  `json:"name"`
	Cmdline string  `json:"cmdline"`
	Memory  int64   `json:"memory"`
	Time    float64 `json:"time"`
	Pid     int64   `json:"pid"`
}

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 Maint

type Maint struct {
	Clock   MaintClockReq `json:"clock"`
	Timeout string        `json:"timeout"`
}

type MaintClockDiff

type MaintClockDiff struct {
	Time      int64 `json:"time"`
	Dangerous bool  `json:"dangerous"`
}

type MaintClockRep

type MaintClockRep struct {
	Sync MaintClockSync `json:"sync"`
	Diff MaintClockDiff `json:"diff"`
}

type MaintClockReq

type MaintClockReq struct {
	Sync bool  `json:"sync"`
	Time int64 `json:"time"`
}

type MaintClockSync

type MaintClockSync struct {
	Status int64 `json:"status"`
}

type MaintReply

type MaintReply struct {
	Clock MaintClockRep `json:"clock"`
	Error string        `json:"error"`
}

type Mainter

type Mainter interface {
	Init(context.Context) error
	Deinit(context.Context) error
	Run(context.Context) (MaintReply, error)
}

func MainterNew

func MainterNew(_ context.Context, cfg *MainterConfig) Mainter

type MainterConfig

type MainterConfig struct {
	Config config.Config
	Data   Proto
}

func MainterDefaultConfig

func MainterDefaultConfig() *MainterConfig

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"`
	Maint  Maint  `json:"maint"`
}

type Task

type Task struct {
	Name     string      `json:"name"`
	File     TaskFile    `json:"file"`
	Params   []TaskParam `json:"params"`
	Commands []string    `json:"commands"`
	Log      TaskLog     `json:"log"`
	Timeout  string      `json:"timeout"`
	Depends  []string    `json:"depends"`
}

type TaskFile

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

type TaskLog

type TaskLog struct {
	Width int64 `json:"width"`
}

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 Tasker

type Tasker interface {
	Init(context.Context) error
	Deinit(context.Context) error
	Run(context.Context) error
	Tail(ctx context.Context) _runner.Log
	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