jobmanager

Documentation

Index

• func JobRun(jobId string) error
• func JobStop(jobId string) error
• func Reg(fileData []byte)
• func RegByUserConfig() error
• func RunStartTime() time.Time
• func RunTask(taskId string) error
• func StopAll()
• type BaseConfig
  • func GetHttpConfig() BaseConfig
• type Job
• type JobConfig
• type JobListManager
• type JobStatus
  • func JobList() []JobStatus
  • func TaskList() []JobStatus
• type OutputType
• type RunOptions
• type RunStatus
  • func (d RunStatus) String() string

Functions

func JobRun

func JobRun(jobId string) error

func JobStop

func JobStop(jobId string) error

func Reg

func Reg(fileData []byte)

func RegByUserConfig

func RegByUserConfig() error

func RunStartTime

func RunStartTime() time.Time

func RunTask

func RunTask(taskId string) error

func StopAll

func StopAll()

Types

type BaseConfig

type BaseConfig struct {
	Dashboard struct {
		Port int `json:"port"`
	} `json:"dashboard"`
}

func GetHttpConfig

func GetHttpConfig() BaseConfig

type Job

type Job struct {
	JobName string     `json:"jobName"`
	BinPath string     `json:"binPath"`
	Params  []string   `json:"params"`
	Dir     string     `json:"dir"`
	Timer   bool       `json:"timer"`
	Spec    string     `json:"spec"`
	Run     bool       `json:"run"`
	Options RunOptions `json:"options"` // 运行选项
}

type JobConfig

type JobConfig struct {
	ResidentTask  []Job      `json:"residentTask"`
	ScheduledTask []Job      `json:"scheduledTask"`
	Config        BaseConfig `json:"config"`
}

type JobListManager

type JobListManager struct {
	// contains filtered or unexported fields
}

type JobStatus

type JobStatus struct {
	Status  RunStatus `json:"status"`
	Name    string    `json:"name"`
	OpenRun bool      `json:"openRun"`
	Type    int       `json:"type"` // 1 是job 2是 task
}

func JobList

func JobList() []JobStatus

func TaskList

func TaskList() []JobStatus

type OutputType

type OutputType int

const (
	OutputTypeStd  OutputType = iota // 输出到标准输入输出
	OutputTypeFile                   // 输出到文件
)

type RunOptions

type RunOptions struct {
	OutputType  OutputType `json:"outputType"`  // 输出方式
	OutputPath  string     `json:"outputPath"`  // 输出路径
	MaxFailures int        `json:"maxFailures"` // 最大失败次数
}

type RunStatus

type RunStatus int

const (
	Stop RunStatus = iota
	Running
)

func (RunStatus) String

func (d RunStatus) String() string