cron

Documentation

Index

• type CronCronTFJobBuilder
  • func NewCronTFJobBuilder() *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) Annotations(annotations map[string]string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) Build() (*Job, error)
  • func (c *CronCronTFJobBuilder) ChiefCPU(cpu string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) ChiefMemory(mem string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) ChiefPort(port int) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) ChiefSelectors(selectors map[string]string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) CleanPodPolicy(policy string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) Command(args []string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) ConcurrencyPolicy(concurrencyPolicy string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) ConfigFiles(files map[string]string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) DataDirs(volumes map[string]string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) Datas(volumes map[string]string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) Deadline(deadline string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) EnableChief() *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) EnableEvaluator() *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) EnableRDMA() *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) EnableTensorboard() *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) Envs(envs map[string]string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) EvaluatorCPU(cpu string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) EvaluatorMemory(mem string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) EvaluatorSelectors(selectors map[string]string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) GPUCount(count int) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) HistoryLimit(historyLimit int) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) Image(image string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) ImagePullSecrets(secrets []string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) LogDir(dir string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) Name(name string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) NodeSelectors(selectors map[string]string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) Priority(priority string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) PsCPU(cpu string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) PsCount(count int) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) PsImage(image string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) PsMemory(mem string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) PsPort(port int) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) PsSelectors(selectors map[string]string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) RoleSequence(roles []string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) Schedule(schedule string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) SyncImage(image string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) SyncMode(mode string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) SyncSource(source string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) TensorboardImage(image string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) Tolerations(tolerations []string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) WorkerCPU(cpu string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) WorkerCount(count int) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) WorkerImage(image string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) WorkerMemory(mem string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) WorkerPort(port int) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) WorkerSelectors(selectors map[string]string) *CronCronTFJobBuilder
  • func (c *CronCronTFJobBuilder) WorkingDir(dir string) *CronCronTFJobBuilder
• type Job
  • func NewJob(name string, jobType types.CronType, args interface{}) *Job
  • func (b *Job) Args() interface{}
  • func (b *Job) Name() string
  • func (j *Job) Type() types.CronType

Types

type CronCronTFJobBuilder

type CronCronTFJobBuilder struct {
	argsbuilder.ArgsBuilder
	// contains filtered or unexported fields
}

func NewCronTFJobBuilder

func NewCronTFJobBuilder() *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) Annotations

func (c *CronCronTFJobBuilder) Annotations(annotations map[string]string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) Build

func (c *CronCronTFJobBuilder) Build() (*Job, error)

func (*CronCronTFJobBuilder) ChiefCPU

func (c *CronCronTFJobBuilder) ChiefCPU(cpu string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) ChiefMemory

func (c *CronCronTFJobBuilder) ChiefMemory(mem string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) ChiefPort

func (c *CronCronTFJobBuilder) ChiefPort(port int) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) ChiefSelectors

func (c *CronCronTFJobBuilder) ChiefSelectors(selectors map[string]string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) CleanPodPolicy

func (c *CronCronTFJobBuilder) CleanPodPolicy(policy string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) Command

func (c *CronCronTFJobBuilder) Command(args []string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) ConcurrencyPolicy

func (c *CronCronTFJobBuilder) ConcurrencyPolicy(concurrencyPolicy string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) ConfigFiles

func (c *CronCronTFJobBuilder) ConfigFiles(files map[string]string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) DataDirs

func (c *CronCronTFJobBuilder) DataDirs(volumes map[string]string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) Datas

func (c *CronCronTFJobBuilder) Datas(volumes map[string]string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) Deadline

func (c *CronCronTFJobBuilder) Deadline(deadline string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) EnableChief

func (c *CronCronTFJobBuilder) EnableChief() *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) EnableEvaluator

func (c *CronCronTFJobBuilder) EnableEvaluator() *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) EnableRDMA

func (c *CronCronTFJobBuilder) EnableRDMA() *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) EnableTensorboard

func (c *CronCronTFJobBuilder) EnableTensorboard() *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) Envs

func (c *CronCronTFJobBuilder) Envs(envs map[string]string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) EvaluatorCPU

func (c *CronCronTFJobBuilder) EvaluatorCPU(cpu string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) EvaluatorMemory

func (c *CronCronTFJobBuilder) EvaluatorMemory(mem string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) EvaluatorSelectors

func (c *CronCronTFJobBuilder) EvaluatorSelectors(selectors map[string]string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) GPUCount

func (c *CronCronTFJobBuilder) GPUCount(count int) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) HistoryLimit

func (c *CronCronTFJobBuilder) HistoryLimit(historyLimit int) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) Image

func (c *CronCronTFJobBuilder) Image(image string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) ImagePullSecrets

func (c *CronCronTFJobBuilder) ImagePullSecrets(secrets []string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) LogDir

func (c *CronCronTFJobBuilder) LogDir(dir string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) Name

func (c *CronCronTFJobBuilder) Name(name string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) NodeSelectors

func (c *CronCronTFJobBuilder) NodeSelectors(selectors map[string]string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) Priority

func (c *CronCronTFJobBuilder) Priority(priority string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) PsCPU

func (c *CronCronTFJobBuilder) PsCPU(cpu string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) PsCount

func (c *CronCronTFJobBuilder) PsCount(count int) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) PsImage

func (c *CronCronTFJobBuilder) PsImage(image string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) PsMemory

func (c *CronCronTFJobBuilder) PsMemory(mem string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) PsPort

func (c *CronCronTFJobBuilder) PsPort(port int) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) PsSelectors

func (c *CronCronTFJobBuilder) PsSelectors(selectors map[string]string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) RoleSequence

func (c *CronCronTFJobBuilder) RoleSequence(roles []string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) Schedule

func (c *CronCronTFJobBuilder) Schedule(schedule string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) SyncImage

func (c *CronCronTFJobBuilder) SyncImage(image string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) SyncMode

func (c *CronCronTFJobBuilder) SyncMode(mode string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) SyncSource

func (c *CronCronTFJobBuilder) SyncSource(source string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) TensorboardImage

func (c *CronCronTFJobBuilder) TensorboardImage(image string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) Tolerations

func (c *CronCronTFJobBuilder) Tolerations(tolerations []string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) WorkerCPU

func (c *CronCronTFJobBuilder) WorkerCPU(cpu string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) WorkerCount

func (c *CronCronTFJobBuilder) WorkerCount(count int) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) WorkerImage

func (c *CronCronTFJobBuilder) WorkerImage(image string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) WorkerMemory

func (c *CronCronTFJobBuilder) WorkerMemory(mem string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) WorkerPort

func (c *CronCronTFJobBuilder) WorkerPort(port int) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) WorkerSelectors

func (c *CronCronTFJobBuilder) WorkerSelectors(selectors map[string]string) *CronCronTFJobBuilder

func (*CronCronTFJobBuilder) WorkingDir

func (c *CronCronTFJobBuilder) WorkingDir(dir string) *CronCronTFJobBuilder

type Job

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

Job defines the base job

func NewJob

func NewJob(name string, jobType types.CronType, args interface{}) *Job

func (*Job) Args

func (b *Job) Args() interface{}

func (*Job) Name

func (b *Job) Name() string

func (*Job) Type

func (j *Job) Type() types.CronType