Documentation
¶
Index ¶
- Variables
- func GetWorkloadNameForXGBoostJob(jobName string) string
- func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error
- func SetupXGBoostJobWebhook(mgr ctrl.Manager, opts ...jobframework.Option) error
- type JobControl
- func (j *JobControl) GVK() schema.GroupVersionKind
- func (j *JobControl) JobStatus() *kftraining.JobStatus
- func (j *JobControl) Object() client.Object
- func (j *JobControl) OrderedReplicaTypes() []kftraining.ReplicaType
- func (j *JobControl) ReplicaSpecs() map[kftraining.ReplicaType]*kftraining.ReplicaSpec
- func (j *JobControl) RunPolicy() *kftraining.RunPolicy
- type XGBoostJobWebhook
- func (w *XGBoostJobWebhook) Default(ctx context.Context, obj runtime.Object) error
- func (w *XGBoostJobWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
- func (w *XGBoostJobWebhook) ValidateDelete(context.Context, runtime.Object) (admission.Warnings, error)
- func (w *XGBoostJobWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var (
FrameworkName = "kubeflow.org/xgboostjob"
)
View Source
var NewReconciler = jobframework.NewGenericReconcilerFactory(func() jobframework.GenericJob { return &kubeflowjob.KubeflowJob{KFJobControl: &JobControl{}} })
Functions ¶
func SetupIndexes ¶
func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error
func SetupXGBoostJobWebhook ¶
func SetupXGBoostJobWebhook(mgr ctrl.Manager, opts ...jobframework.Option) error
Types ¶
type JobControl ¶
type JobControl kftraining.XGBoostJob
func (*JobControl) GVK ¶
func (j *JobControl) GVK() schema.GroupVersionKind
func (*JobControl) JobStatus ¶
func (j *JobControl) JobStatus() *kftraining.JobStatus
func (*JobControl) Object ¶
func (j *JobControl) Object() client.Object
func (*JobControl) OrderedReplicaTypes ¶
func (j *JobControl) OrderedReplicaTypes() []kftraining.ReplicaType
func (*JobControl) ReplicaSpecs ¶
func (j *JobControl) ReplicaSpecs() map[kftraining.ReplicaType]*kftraining.ReplicaSpec
func (*JobControl) RunPolicy ¶
func (j *JobControl) RunPolicy() *kftraining.RunPolicy
type XGBoostJobWebhook ¶
type XGBoostJobWebhook struct {
// contains filtered or unexported fields
}
func (*XGBoostJobWebhook) Default ¶
Default implements webhook.CustomDefaulter so a webhook will be registered for the type
func (*XGBoostJobWebhook) ValidateCreate ¶
func (w *XGBoostJobWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type
func (*XGBoostJobWebhook) ValidateDelete ¶
func (w *XGBoostJobWebhook) ValidateDelete(context.Context, runtime.Object) (admission.Warnings, error)
ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type
func (*XGBoostJobWebhook) ValidateUpdate ¶
func (w *XGBoostJobWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
ValidateUpdate implements webhook.CustomValidator so a webhook will be registered for the type
Source Files
Click to show internal directories.
Click to hide internal directories.