pytorchjob

Oct 25, 2023

Changes in this version

+ var FrameworkName = "kubeflow.org/pytorchjob"

+ var NewReconciler = jobframework.NewGenericReconciler(func() jobframework.GenericJob { ... }, nil)

+ func GetWorkloadNameForPyTorchJob(jobName string) string

+ func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error

+ func SetupPyTorchJobWebhook(mgr ctrl.Manager, opts ...jobframework.Option) error

+ type JobControl kftraining.PyTorchJob

+ 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 PyTorchJobWebhook struct

+ func (w *PyTorchJobWebhook) Default(ctx context.Context, obj runtime.Object) error

+ func (w *PyTorchJobWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)

+ func (w *PyTorchJobWebhook) ValidateDelete(context.Context, runtime.Object) (admission.Warnings, error)

+ func (w *PyTorchJobWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)