util

Documentation

Index

• Constants
• func ConvertPodList(list []corev1.Pod) []*corev1.Pod
• func ConvertPodListWithFilter(list []corev1.Pod, pass ObjectFilterFunction) []*corev1.Pod
• func ConvertServiceList(list []corev1.Service) []*corev1.Service
• func DurationUntilExpireTime(runPolicy *commonv1.RunPolicy, jobStatus commonv1.JobStatus) (time.Duration, error)
• func GenExpectationGenericKey(jobKey string, replicaType string, pl string) string
• func GetReplicaTypes(specs map[commonv1.ReplicaType]*commonv1.ReplicaSpec) []commonv1.ReplicaType
• func GetSchedulerName(replicas map[commonv1.ReplicaType]*commonv1.ReplicaSpec) string
• func IsGangSchedulerSet(replicas map[commonv1.ReplicaType]*commonv1.ReplicaSpec, schedulerName string) bool
• func LoggerForGenericKind(obj metav1.Object, kind string) *log.Entry
• func OnDependentCreateFunc(exp expectation.ControllerExpectationsInterface) func(event.CreateEvent) bool
• func OnDependentCreateFuncGeneric(exp expectation.ControllerExpectationsInterface) func(event.CreateEvent) bool
• func OnDependentDeleteFunc(exp expectation.ControllerExpectationsInterface) func(event.DeleteEvent) bool
• func OnDependentDeleteFuncGeneric(exp expectation.ControllerExpectationsInterface) func(event.DeleteEvent) bool
• func OnDependentUpdateFunc(jc *common.JobController) func(updateEvent event.UpdateEvent) bool
• func OnDependentUpdateFuncGeneric(jc *common.JobController) func(updateEvent event.UpdateEvent) bool
• func SatisfiedExpectations(exp expectation.ControllerExpectationsInterface, jobKey string, ...) bool
• type FakeWorkQueue
  • func (f *FakeWorkQueue) Add(item interface{})
  • func (f *FakeWorkQueue) AddAfter(item interface{}, duration time.Duration)
  • func (f *FakeWorkQueue) AddRateLimited(item interface{})
  • func (f *FakeWorkQueue) Done(item interface{})
  • func (f *FakeWorkQueue) Forget(item interface{})
  • func (f *FakeWorkQueue) Get() (item interface{}, shutdown bool)
  • func (f *FakeWorkQueue) Len() int
  • func (f *FakeWorkQueue) NumRequeues(item interface{}) int
  • func (f *FakeWorkQueue) ShutDown()
  • func (f *FakeWorkQueue) ShutDownWithDrain()
  • func (f *FakeWorkQueue) ShuttingDown() bool
• type ObjectFilterFunction

Constants

const (
	DefaultGangSchedulerName = "volcano"
)

Functions

func ConvertPodList

func ConvertPodList(list []corev1.Pod) []*corev1.Pod

ConvertPodList convert pod list to pod pointer list

func ConvertPodListWithFilter

func ConvertPodListWithFilter(list []corev1.Pod, pass ObjectFilterFunction) []*corev1.Pod

ConvertPodListWithFilter converts pod list to pod pointer list with ObjectFilterFunction

func ConvertServiceList

func ConvertServiceList(list []corev1.Service) []*corev1.Service

ConvertServiceList convert service list to service point list

func DurationUntilExpireTime

func DurationUntilExpireTime(runPolicy *commonv1.RunPolicy, jobStatus commonv1.JobStatus) (time.Duration, error)

DurationUntilExpireTime returns the duration until job needs to be cleaned up, or -1 if it's infinite.

func GenExpectationGenericKey

func GenExpectationGenericKey(jobKey string, replicaType string, pl string) string

GenExpectationGenericKey generates an expectation key for {Kind} of a job

func GetReplicaTypes

func GetReplicaTypes(specs map[commonv1.ReplicaType]*commonv1.ReplicaSpec) []commonv1.ReplicaType

func GetSchedulerName

func GetSchedulerName(replicas map[commonv1.ReplicaType]*commonv1.ReplicaSpec) string

func IsGangSchedulerSet

func IsGangSchedulerSet(replicas map[commonv1.ReplicaType]*commonv1.ReplicaSpec, schedulerName string) bool

func LoggerForGenericKind

func LoggerForGenericKind(obj metav1.Object, kind string) *log.Entry

LoggerForGenericKind generates log entry for generic Kubernetes resource Kind

func OnDependentCreateFunc

func OnDependentCreateFunc(exp expectation.ControllerExpectationsInterface) func(event.CreateEvent) bool

OnDependentCreateFunc modify expectations when dependent (pod/service) creation observed.

func OnDependentCreateFuncGeneric

func OnDependentCreateFuncGeneric(exp expectation.ControllerExpectationsInterface) func(event.CreateEvent) bool

OnDependentCreateFuncGeneric modify expectations when dependent (pod/service) creation observed.

func OnDependentDeleteFunc

func OnDependentDeleteFunc(exp expectation.ControllerExpectationsInterface) func(event.DeleteEvent) bool

OnDependentDeleteFunc modify expectations when dependent (pod/service) deletion observed.

func OnDependentDeleteFuncGeneric

func OnDependentDeleteFuncGeneric(exp expectation.ControllerExpectationsInterface) func(event.DeleteEvent) bool

OnDependentDeleteFuncGeneric modify expectations when dependent (pod/service) deletion observed.

func OnDependentUpdateFunc

func OnDependentUpdateFunc(jc *common.JobController) func(updateEvent event.UpdateEvent) bool

OnDependentUpdateFunc modify expectations when dependent (pod/service) update observed.

func OnDependentUpdateFuncGeneric

func OnDependentUpdateFuncGeneric(jc *common.JobController) func(updateEvent event.UpdateEvent) bool

OnDependentUpdateFuncGeneric modify expectations when dependent (pod/service) update observed.

func SatisfiedExpectations

func SatisfiedExpectations(exp expectation.ControllerExpectationsInterface, jobKey string, replicaTypes []commonv1.ReplicaType) bool

SatisfiedExpectations returns true if the required adds/dels for the given mxjob have been observed. Add/del counts are established by the controller at sync time, and updated as controllees are observed by the controller manager.

Types

type FakeWorkQueue

type FakeWorkQueue struct{}

FakeWorkQueue implements RateLimitingInterface but actually does nothing.

func (*FakeWorkQueue) Add

func (f *FakeWorkQueue) Add(item interface{})

Add WorkQueue Add method

func (*FakeWorkQueue) AddAfter

func (f *FakeWorkQueue) AddAfter(item interface{}, duration time.Duration)

AddAfter WorkQueue AddAfter method

func (*FakeWorkQueue) AddRateLimited

func (f *FakeWorkQueue) AddRateLimited(item interface{})

AddRateLimited WorkQueue AddRateLimited method

func (*FakeWorkQueue) Done

func (f *FakeWorkQueue) Done(item interface{})

Done WorkQueue Done method

func (*FakeWorkQueue) Forget

func (f *FakeWorkQueue) Forget(item interface{})

Forget WorkQueue Forget method

func (*FakeWorkQueue) Get

func (f *FakeWorkQueue) Get() (item interface{}, shutdown bool)

Get WorkQueue Get method

func (*FakeWorkQueue) Len

func (f *FakeWorkQueue) Len() int

Len WorkQueue Len method

func (*FakeWorkQueue) NumRequeues

func (f *FakeWorkQueue) NumRequeues(item interface{}) int

NumRequeues WorkQueue NumRequeues method

func (*FakeWorkQueue) ShutDown

func (f *FakeWorkQueue) ShutDown()

ShutDown WorkQueue ShutDown method

func (*FakeWorkQueue) ShutDownWithDrain

func (f *FakeWorkQueue) ShutDownWithDrain()

ShutDown WorkQueue ShutDownWithDrain method

func (*FakeWorkQueue) ShuttingDown

func (f *FakeWorkQueue) ShuttingDown() bool

ShuttingDown WorkQueue ShuttingDown method

type ObjectFilterFunction

type ObjectFilterFunction func(obj metav1.Object) bool