util

Documentation

Index

• Constants
• func ConvertPodList(list []corev1.Pod) []*corev1.Pod
• func ConvertServiceList(list []corev1.Service) []*corev1.Service
• func GenExpectationGenericKey(jobKey string, replicaType string, pl string) string
• func GetDelegatingClientFromClient(c client.Client) (client.Client, error)
• 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) ShuttingDown() bool

Constants

const (
	DefaultGangSchedulerName = "volcano"
)

Functions

func ConvertPodList

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

ConvertPodList convert pod list to pod pointer list

func ConvertServiceList

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

ConvertServiceList convert service list to service point list

func GenExpectationGenericKey

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

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

func GetDelegatingClientFromClient

func GetDelegatingClientFromClient(c client.Client) (client.Client, error)

TODO (Jeffwan@): Find an elegant way to either use delegatingReader or directly use clientss GetDelegatingClientFromClient try to extract client reader from client, client reader reads cluster info from api client.

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) ShuttingDown

func (f *FakeWorkQueue) ShuttingDown() bool

ShuttingDown WorkQueue ShuttingDown method