Documentation
¶
Index ¶
- func ConvertServiceList(list []corev1.Service) []*corev1.Service
- func DurationUntilExpireTime(runPolicy *kubeflowv1.RunPolicy, jobStatus kubeflowv1.JobStatus) (time.Duration, error)
- func GenExpectationGenericKey(jobKey string, replicaType string, pl string) string
- func GetReplicaTypes(specs map[kubeflowv1.ReplicaType]*kubeflowv1.ReplicaSpec) []kubeflowv1.ReplicaType
- func GetSchedulerName(replicas map[kubeflowv1.ReplicaType]*kubeflowv1.ReplicaSpec) string
- func IsGangSchedulerSet(replicas map[kubeflowv1.ReplicaType]*kubeflowv1.ReplicaSpec, ...) bool
- func JobControlledPodList(list []corev1.Pod, job metav1.Object) []*corev1.Pod
- func LoggerForGenericKind(obj metav1.Object, kind string) *log.Entry
- func OnDependentCreateFuncGeneric[T client.Object](s *runtime.Scheme, exp expectation.ControllerExpectationsInterface) func(createEvent event.TypedCreateEvent[T]) bool
- func OnDependentDeleteFuncGeneric[T client.Object](s *runtime.Scheme, exp expectation.ControllerExpectationsInterface) func(event.TypedDeleteEvent[T]) bool
- func OnDependentFuncs[T client.Object](s *runtime.Scheme, expectations expectation.ControllerExpectationsInterface, ...) predicate.TypedFuncs[T]
- func OnDependentUpdateFuncGeneric[T client.Object](_ *runtime.Scheme, jc *common.JobController) func(updateEvent event.TypedUpdateEvent[T]) bool
- func SatisfiedExpectations(exp expectation.ControllerExpectationsInterface, jobKey string, ...) bool
- func ValidateRunPolicy(runPolicy *v1.RunPolicy) field.ErrorList
- func ValidateRunPolicyUpdate(oldRunPolicy, newRunPolicy *v1.RunPolicy) field.ErrorList
- type FakeWorkQueue
- func (f *FakeWorkQueue[T]) Add(item T)
- func (f *FakeWorkQueue[T]) AddAfter(item T, duration time.Duration)
- func (f *FakeWorkQueue[T]) AddRateLimited(item T)
- func (f *FakeWorkQueue[T]) Done(item T)
- func (f *FakeWorkQueue[T]) Forget(item T)
- func (f *FakeWorkQueue[T]) Get() (item T, shutdown bool)
- func (f *FakeWorkQueue[T]) Len() int
- func (f *FakeWorkQueue[T]) NumRequeues(item T) int
- func (f *FakeWorkQueue[T]) ShutDown()
- func (f *FakeWorkQueue[T]) ShutDownWithDrain()
- func (f *FakeWorkQueue[T]) ShuttingDown() bool
- type ObjectFilterFunction
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertServiceList ¶
ConvertServiceList convert service list to service point list
func DurationUntilExpireTime ¶ added in v1.5.0
func DurationUntilExpireTime(runPolicy *kubeflowv1.RunPolicy, jobStatus kubeflowv1.JobStatus) (time.Duration, error)
DurationUntilExpireTime returns the duration until job needs to be cleaned up, or -1 if it's infinite.
func GenExpectationGenericKey ¶
GenExpectationGenericKey generates an expectation key for {Kind} of a job
func GetReplicaTypes ¶
func GetReplicaTypes(specs map[kubeflowv1.ReplicaType]*kubeflowv1.ReplicaSpec) []kubeflowv1.ReplicaType
func GetSchedulerName ¶
func GetSchedulerName(replicas map[kubeflowv1.ReplicaType]*kubeflowv1.ReplicaSpec) string
func IsGangSchedulerSet ¶
func IsGangSchedulerSet(replicas map[kubeflowv1.ReplicaType]*kubeflowv1.ReplicaSpec, schedulerName string) bool
func JobControlledPodList ¶ added in v1.7.0
JobControlledPodList filter pod list owned by the job.
func LoggerForGenericKind ¶
LoggerForGenericKind generates log entry for generic Kubernetes resource Kind
func OnDependentCreateFuncGeneric ¶
func OnDependentCreateFuncGeneric[T client.Object](s *runtime.Scheme, exp expectation.ControllerExpectationsInterface) func(createEvent event.TypedCreateEvent[T]) bool
OnDependentCreateFuncGeneric modify expectations when dependent (pod/service) creation observed.
func OnDependentDeleteFuncGeneric ¶
func OnDependentDeleteFuncGeneric[T client.Object](s *runtime.Scheme, exp expectation.ControllerExpectationsInterface) func(event.TypedDeleteEvent[T]) bool
OnDependentDeleteFuncGeneric modify expectations when dependent deletion observed.
func OnDependentFuncs ¶ added in v1.9.0
func OnDependentFuncs[T client.Object](s *runtime.Scheme, expectations expectation.ControllerExpectationsInterface, jobController *common.JobController) predicate.TypedFuncs[T]
func OnDependentUpdateFuncGeneric ¶
func OnDependentUpdateFuncGeneric[T client.Object](_ *runtime.Scheme, jc *common.JobController) func(updateEvent event.TypedUpdateEvent[T]) bool
OnDependentUpdateFuncGeneric modify expectations when dependent update observed.
func SatisfiedExpectations ¶
func SatisfiedExpectations(exp expectation.ControllerExpectationsInterface, jobKey string, replicaTypes []kubeflowv1.ReplicaType) bool
SatisfiedExpectations returns true if the required adds/dels for the given job have been observed. Add/del counts are established by the controller at sync time, and updated as controllees are observed by the controller manager.
func ValidateRunPolicy ¶ added in v1.9.0
Types ¶
type FakeWorkQueue ¶
type FakeWorkQueue[T any] struct{}
FakeWorkQueue implements RateLimitingInterface but actually does nothing.
func (*FakeWorkQueue[T]) AddAfter ¶
func (f *FakeWorkQueue[T]) AddAfter(item T, duration time.Duration)
AddAfter WorkQueue AddAfter method
func (*FakeWorkQueue[T]) AddRateLimited ¶
func (f *FakeWorkQueue[T]) AddRateLimited(item T)
AddRateLimited WorkQueue AddRateLimited method
func (*FakeWorkQueue[T]) Forget ¶
func (f *FakeWorkQueue[T]) Forget(item T)
Forget WorkQueue Forget method
func (*FakeWorkQueue[T]) Get ¶
func (f *FakeWorkQueue[T]) Get() (item T, shutdown bool)
Get WorkQueue Get method
func (*FakeWorkQueue[T]) NumRequeues ¶
func (f *FakeWorkQueue[T]) NumRequeues(item T) int
NumRequeues WorkQueue NumRequeues method
func (*FakeWorkQueue[T]) ShutDown ¶
func (f *FakeWorkQueue[T]) ShutDown()
ShutDown WorkQueue ShutDown method
func (*FakeWorkQueue[T]) ShutDownWithDrain ¶ added in v1.5.0
func (f *FakeWorkQueue[T]) ShutDownWithDrain()
ShutDownWithDrain WorkQueue ShutDownWithDrain method
func (*FakeWorkQueue[T]) ShuttingDown ¶
func (f *FakeWorkQueue[T]) ShuttingDown() bool
ShuttingDown WorkQueue ShuttingDown method
Source Files