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