executor

type JobModeParams struct {
	JobFlavour string // flavour of job in pod or collective mode

	CollectiveJobReplicas string // parameters for Collective job

	PServerReplicas string // server.replicas or driver.replicas of job
	PServerFlavour  string // server.flavour or driver.flavour of job
	PServerCommand  string // server.command or driver.command of job
	WorkerReplicas  string // worker.replicas or executor.replicas of job
	WorkerFlavour   string // worker.flavour or executor.flavour of job
	WorkerCommand   string // worker.command or executor.command of job
}

type KubeJob struct {
	ID string
	// Name the name of job on kubernetes
	Name        string
	Namespace   string
	JobType     schema.JobType
	JobMode     string
	Image       string
	Command     string
	Env         map[string]string
	Priority    string
	QueueName   string
	Labels      map[string]string
	Annotations map[string]string
	// 存储资源
	FileSystems []schema.FileSystem

	// job framework
	Framework schema.Framework
	// YamlTemplateContent indicate template content of job
	YamlTemplateContent []byte
	IsCustomYaml        bool
	Tasks               []model.Member
	GroupVersionKind    kubeschema.GroupVersionKind
	DynamicClientOption *k8s.DynamicClientOption
}

type KubeJobInterface interface {
	// contains filtered or unexported methods
}

type PaddleJob struct {
	KubeJob
}

type PyTorchJob struct {
	KubeJob
}

type SingleJob struct {
	KubeJob
	Flavour schema.Flavour
}

type SparkJob struct {
	KubeJob
	SparkMainFile    string
	SparkMainClass   string
	SparkArguments   string
	DriverFlavour    string
	ExecutorFlavour  string
	ExecutorReplicas string
}

type TFJob struct {
	KubeJob
}

type VCJob struct {
	KubeJob
	JobModeParams
}

type WorkflowJob struct {
	KubeJob
}