Documentation ¶
Index ¶
- Variables
- func GetWorkloadNameForPaddleJob(jobName string) string
- func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error
- func SetupPaddleJobWebhook(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 PaddleJobWebhook
- func (w *PaddleJobWebhook) Default(ctx context.Context, obj runtime.Object) error
- func (w *PaddleJobWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
- func (w *PaddleJobWebhook) ValidateDelete(context.Context, runtime.Object) (admission.Warnings, error)
- func (w *PaddleJobWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var (
FrameworkName = "kubeflow.org/paddlejob"
)
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 SetupPaddleJobWebhook ¶
func SetupPaddleJobWebhook(mgr ctrl.Manager, opts ...jobframework.Option) error
SetupPaddleJobWebhook configures the webhook for kubeflow PaddleJob.
Types ¶
type JobControl ¶
type JobControl kftraining.PaddleJob
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 PaddleJobWebhook ¶
type PaddleJobWebhook struct {
// contains filtered or unexported fields
}
func (*PaddleJobWebhook) Default ¶
Default implements webhook.CustomDefaulter so a webhook will be registered for the type
func (*PaddleJobWebhook) ValidateCreate ¶
func (w *PaddleJobWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type
func (*PaddleJobWebhook) ValidateDelete ¶
func (w *PaddleJobWebhook) ValidateDelete(context.Context, runtime.Object) (admission.Warnings, error)
ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type
func (*PaddleJobWebhook) ValidateUpdate ¶
func (w *PaddleJobWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
ValidateUpdate implements webhook.CustomValidator so a webhook will be registered for the type
Click to show internal directories.
Click to hide internal directories.