job

Documentation

Index

• Constants
• func MakePodName(jobName string, taskName string, index int) string
• type TaskPriority
• type TasksPriority
  • func (p TasksPriority) CalcFirstCountResources(count int32) v1.ResourceList
  • func (p TasksPriority) CalcPGMinResources(jobMinAvailable int32) v1.ResourceList
  • 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 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) CalcFirstCountResources

func (p TasksPriority) CalcFirstCountResources(count int32) v1.ResourceList

CalcFirstCountResources return the first count tasks resource, sorted by priority

func (TasksPriority) CalcPGMinResources

func (p TasksPriority) CalcPGMinResources(jobMinAvailable int32) v1.ResourceList

CalcPGMinResources sums up all task's min available; if not enough, then fill up to jobMinAvailable via task's replicas

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)