job

Documentation

Index

• Constants
• type JobController
  • func NewJobController(jobInformer batchv1informers.JobInformer, client clientset.Interface) *JobController
  • func (v *JobController) Run(workers int, stopCh <-chan struct{}) error
  • func (v *JobController) Start(ctx context.Context) error
• type JobRevision
• type JobRevisions

Constants

const (
	Running    = "running"
	Failed     = "failed"
	Unfinished = "unfinished"
	Completed  = "completed"
	Pause      = "pause"
)

Types

type JobController

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

func NewJobController

func NewJobController(jobInformer batchv1informers.JobInformer, client clientset.Interface) *JobController

func (*JobController) Run

func (v *JobController) Run(workers int, stopCh <-chan struct{}) error

func (*JobController) Start

func (v *JobController) Start(ctx context.Context) error

type JobRevision

type JobRevision struct {
	Status         string    `json:"status"`
	Reasons        []string  `json:"reasons,omitempty"`
	Messages       []string  `json:"messages,omitempty"`
	Succeed        int32     `json:"succeed,omitempty"`
	DesirePodNum   int32     `json:"desire,omitempty"`
	Failed         int32     `json:"failed,omitempty"`
	Uid            string    `json:"uid"`
	StartTime      time.Time `json:"start-time,omitempty"`
	CompletionTime time.Time `json:"completion-time,omitempty"`
}

type JobRevisions

type JobRevisions map[int]JobRevision