Versions in this module Expand all Collapse all v0 v0.2.0 Mar 24, 2021 Changes in this version + const FailedDeleteJobReason + const RecommendedKubeConfigPathEnv + const SuccessfulDeleteJobReason + func Add(mgr manager.Manager) error + func GetPortFromXGBoostJob(job *v1xgboost.XGBoostJob, rtype v1xgboost.XGBoostJobReplicaType) (int32, error) + func SetPodEnv(job interface{}, podTemplate *corev1.PodTemplateSpec, rtype, index string) error + type FakeWorkQueue struct + 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 + type ReconcileXGBoostJob struct + func (r *ReconcileXGBoostJob) ControllerName() string + func (r *ReconcileXGBoostJob) DeleteJob(job interface{}) error + func (r *ReconcileXGBoostJob) GetAPIGroupVersion() schema.GroupVersion + func (r *ReconcileXGBoostJob) GetAPIGroupVersionKind() schema.GroupVersionKind + func (r *ReconcileXGBoostJob) GetDefaultContainerName() string + func (r *ReconcileXGBoostJob) GetDefaultContainerPortName() string + func (r *ReconcileXGBoostJob) GetGroupNameLabelValue() string + func (r *ReconcileXGBoostJob) GetJobFromAPIClient(namespace, name string) (metav1.Object, error) + func (r *ReconcileXGBoostJob) GetJobFromInformerCache(namespace, name string) (metav1.Object, error) + func (r *ReconcileXGBoostJob) GetJobRoleKey() string + func (r *ReconcileXGBoostJob) GetPodsForJob(obj interface{}) ([]*corev1.Pod, error) + func (r *ReconcileXGBoostJob) GetServicesForJob(obj interface{}) ([]*corev1.Service, error) + func (r *ReconcileXGBoostJob) IsMasterRole(replicas map[commonv1.ReplicaType]*commonv1.ReplicaSpec, ...) bool + func (r *ReconcileXGBoostJob) Reconcile(request reconcile.Request) (reconcile.Result, error) + func (r *ReconcileXGBoostJob) SetClusterSpec(job interface{}, podTemplate *corev1.PodTemplateSpec, rtype, index string) error + func (r *ReconcileXGBoostJob) UpdateJobStatus(job interface{}, replicas map[commonv1.ReplicaType]*commonv1.ReplicaSpec, ...) error + func (r *ReconcileXGBoostJob) UpdateJobStatusInApiServer(job interface{}, jobStatus *commonv1.JobStatus) error