job

Documentation

Index

• Constants
• 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)

Constants

const (
	// FailedCreatePodReason is added in an event and in a replica set condition
	// when a pod for a replica set is failed to be created.
	FailedCreatePodReason = "FailedCreate"
	// SuccessfulCreatePodReason is added in an event when a pod for a replica set
	// is successfully created.
	SuccessfulCreatePodReason = "SuccessfulCreate"
	// FailedDeletePodReason is added in an event and in a replica set condition
	// when a pod for a replica set is failed to be deleted.
	FailedDeletePodReason = "FailedDelete"
	// SuccessfulDeletePodReason is added in an event when a pod for a replica set
	// is successfully deleted.
	SuccessfulDeletePodReason = "SuccessfulDelete"
)

Reasons for pod events

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)