job

Documentation

Index

• func MakePodName(jobName string, taskName string, index int) string
• type Controller
  • func NewJobController(kubeClient kubernetes.Interface, vcClient vcclientset.Interface, ...) *Controller
  • func (cc *Controller) Run(stopCh <-chan struct{})
• type TaskPriority
• type TasksPriority
  • func (p TasksPriority) Len() int
  • func (p TasksPriority) Less(i, j int) bool
  • func (p TasksPriority) Swap(i, j int)

Functions

func MakePodName

func MakePodName(jobName string, taskName string, index int) string

MakePodName append podname,jobname,taskName and index and returns the string

Types

type Controller

type Controller struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Controller the Job Controller type

func NewJobController

func NewJobController(
	kubeClient kubernetes.Interface,
	vcClient vcclientset.Interface,
	sharedInformers informers.SharedInformerFactory,
	workers uint32,
) *Controller

NewJobController create new Job Controller

func (*Controller) Run

func (cc *Controller) Run(stopCh <-chan struct{})

Run start JobController

type TaskPriority

type TaskPriority struct {
	batch.TaskSpec
	// contains filtered or unexported fields
}

TaskPriority structure

type TasksPriority

type TasksPriority []TaskPriority

TasksPriority is a slice of TaskPriority

func (TasksPriority) Len

func (p TasksPriority) Len() int

func (TasksPriority) Less

func (p TasksPriority) Less(i, j int) bool

func (TasksPriority) Swap

func (p TasksPriority) Swap(i, j int)