jobset

package
v0.10.0-devel Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 5, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	FrameworkName = "jobset.x-k8s.io/jobset"
)

Functions

func GetWorkloadNameForJobSet

func GetWorkloadNameForJobSet(jobSetName string, jobSetUID types.UID) string

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

type JobSet jobsetapi.JobSet

func (*JobSet) Finished

func (j *JobSet) Finished() (message string, success, finished bool)

func (*JobSet) GVK added in v0.5.0

func (j *JobSet) GVK() schema.GroupVersionKind

func (*JobSet) IsActive

func (j *JobSet) IsActive() bool

func (*JobSet) IsSuspended

func (j *JobSet) IsSuspended() bool

func (*JobSet) Object

func (j *JobSet) Object() client.Object

func (*JobSet) PodLabelSelector added in v0.9.0

func (j *JobSet) PodLabelSelector() string

func (*JobSet) PodSets

func (j *JobSet) PodSets() []kueue.PodSet

func (*JobSet) PodsReady

func (j *JobSet) PodsReady() bool

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

func (*JobSet) Suspend

func (j *JobSet) Suspend()

type JobSetWebhook

type JobSetWebhook struct {
	// contains filtered or unexported fields
}

func (*JobSetWebhook) Default

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL