Documentation
¶
Index ¶
- Variables
- func GetWorkloadNameForMXJob(jobName string) string
- func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error
- func SetupMXJobWebhook(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 MXJobWebhook
- func (w *MXJobWebhook) Default(ctx context.Context, obj runtime.Object) error
- func (w *MXJobWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
- func (w *MXJobWebhook) ValidateDelete(context.Context, runtime.Object) (admission.Warnings, error)
- func (w *MXJobWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var (
FrameworkName = "kubeflow.org/mxjob"
)
View Source
var NewReconciler = jobframework.NewGenericReconcilerFactory(func() jobframework.GenericJob { return &kubeflowjob.KubeflowJob{KFJobControl: &JobControl{}} })
Functions ¶
func GetWorkloadNameForMXJob ¶
func SetupIndexes ¶
func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error
func SetupMXJobWebhook ¶
func SetupMXJobWebhook(mgr ctrl.Manager, opts ...jobframework.Option) error
SetupMXJobWebhook configures the webhook for kubeflow MXJob.
Types ¶
type JobControl ¶
type JobControl kftraining.MXJob
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 MXJobWebhook ¶
type MXJobWebhook struct {
// contains filtered or unexported fields
}
func (*MXJobWebhook) Default ¶
Default implements webhook.CustomDefaulter so a webhook will be registered for the type
func (*MXJobWebhook) ValidateCreate ¶
func (w *MXJobWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type
func (*MXJobWebhook) ValidateDelete ¶
ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type
func (*MXJobWebhook) ValidateUpdate ¶
func (w *MXJobWebhook) 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.