job_manager

type Job interface {
	JobName() string
	Exec() error
}

type JobCephStatus struct {
	JobCephStatusCaller
}

type JobCephStatusCaller interface {
	interfacer.Worker
	RunTime() int64
	HandleCephStatusList(list ceph_cluster.CephStatusList)
}

type JobFio struct {
	fio.Fio
	interfacer.Worker
}

type JobJobCost struct {
	RunTime int64   `json:"runtime"`
	OsdIDs  []int64 `json:"osdIDs"`
	interfacer.Worker
}

type JobManager struct {
	*ceph_cluster.CephCluster
	*ceph.CephConf
	PipeLine PipeLine `json:"pipeLine"`
}

type JobSleep struct {
	Time int64 `json:"time"`
}

type PipeLine struct {
	Job
	// 并行job
	ParallelJobs []PipeLine `json:"parallelJobs"`
	// 串行job
	SerialJobs []PipeLine `json:"serialJobs"`
}