Documentation ¶
Index ¶
- Variables
- func GetWorkloadNameForJobSet(jobSetName string, jobSetUID types.UID) string
- func NewJob() jobframework.GenericJob
- func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error
- func SetupJobSetWebhook(mgr ctrl.Manager, opts ...jobframework.Option) error
- type JobSet
- func (j *JobSet) Finished() (message string, success, finished bool)
- func (j *JobSet) GVK() schema.GroupVersionKind
- func (j *JobSet) IsActive() bool
- func (j *JobSet) IsSuspended() bool
- func (j *JobSet) Object() client.Object
- func (j *JobSet) PodLabelSelector() string
- func (j *JobSet) PodSets() []kueue.PodSet
- func (j *JobSet) PodsReady() bool
- func (j *JobSet) ReclaimablePods() ([]kueue.ReclaimablePod, error)
- func (j *JobSet) RestorePodSetsInfo(podSetsInfo []podset.PodSetInfo) bool
- func (j *JobSet) RunWithPodSetsInfo(podSetsInfo []podset.PodSetInfo) error
- func (j *JobSet) Suspend()
- type JobSetWebhook
- func (w *JobSetWebhook) Default(ctx context.Context, obj runtime.Object) error
- func (w *JobSetWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
- func (w *JobSetWebhook) ValidateDelete(_ context.Context, _ runtime.Object) (admission.Warnings, error)
- func (w *JobSetWebhook) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var (
FrameworkName = "jobset.x-k8s.io/jobset"
)
View Source
var NewReconciler = jobframework.NewGenericReconcilerFactory(NewJob)
Functions ¶
func NewJob ¶ added in v0.9.0
func NewJob() jobframework.GenericJob
func SetupIndexes ¶
func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error
func SetupJobSetWebhook ¶
func SetupJobSetWebhook(mgr ctrl.Manager, opts ...jobframework.Option) error
SetupJobSetWebhook configures the webhook for kubeflow JobSet.
Types ¶
type JobSet ¶
func (*JobSet) GVK ¶ added in v0.5.0
func (j *JobSet) GVK() schema.GroupVersionKind
func (*JobSet) IsSuspended ¶
func (*JobSet) PodLabelSelector ¶ added in v0.9.0
func (*JobSet) ReclaimablePods ¶
func (j *JobSet) ReclaimablePods() ([]kueue.ReclaimablePod, error)
func (*JobSet) RestorePodSetsInfo ¶
func (j *JobSet) RestorePodSetsInfo(podSetsInfo []podset.PodSetInfo) bool
func (*JobSet) RunWithPodSetsInfo ¶
func (j *JobSet) RunWithPodSetsInfo(podSetsInfo []podset.PodSetInfo) error
type JobSetWebhook ¶
type JobSetWebhook struct {
// contains filtered or unexported fields
}
func (*JobSetWebhook) Default ¶
Default implements webhook.CustomDefaulter so a webhook will be registered for the type
func (*JobSetWebhook) ValidateCreate ¶
func (w *JobSetWebhook) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type
func (*JobSetWebhook) ValidateDelete ¶
func (w *JobSetWebhook) ValidateDelete(_ context.Context, _ runtime.Object) (admission.Warnings, error)
ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type
func (*JobSetWebhook) ValidateUpdate ¶
func (w *JobSetWebhook) 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.