Versions in this module Expand all Collapse all v1 v1.9.2 Apr 14, 2025 Changes in this version + const Name + var ClusterTrainingRuntimeContainerRuntimeClassKey = ".clusterTrainingRuntimeSpec.jobSetTemplateSpec.replicatedJobs.podTemplateSpec.runtimeClassName" + var ErrorCanNotSetupClusterTrainingRuntimeRuntimeClassIndexer = errors.New("setting index on runtimeClass for ClusterTrainingRuntime") + var ErrorCanNotSetupTrainingRuntimeRuntimeClassIndexer = errors.New("setting index on runtimeClass for TrainingRuntime") + var TrainingRuntimeContainerRuntimeClassKey = ".trainingRuntimeSpec.jobSetTemplateSpec.replicatedJobs.podTemplateSpec.runtimeClassName" + func IndexClusterTrainingRuntimeContainerRuntimeClass(obj client.Object) []string + func IndexTrainingRuntimeContainerRuntimeClass(obj client.Object) []string + func New(ctx context.Context, c client.Client, indexer client.FieldIndexer) (framework.Plugin, error) + type CoScheduling struct + func (c *CoScheduling) Build(ctx context.Context, _ client.Object, info *runtime.Info, ...) (client.Object, error) + func (c *CoScheduling) EnforcePodGroupPolicy(info *runtime.Info, trainJob *kubeflowv2.TrainJob) error + func (c *CoScheduling) Name() string + func (c *CoScheduling) ReconcilerBuilders() []runtime.ReconcilerBuilder + type PodGroupLimitRangeHandler struct + func (h *PodGroupLimitRangeHandler) Create(ctx context.Context, e event.TypedCreateEvent[*corev1.LimitRange], ...) + func (h *PodGroupLimitRangeHandler) Delete(ctx context.Context, e event.TypedDeleteEvent[*corev1.LimitRange], ...) + func (h *PodGroupLimitRangeHandler) Generic(context.Context, event.TypedGenericEvent[*corev1.LimitRange], ...) + func (h *PodGroupLimitRangeHandler) Update(ctx context.Context, e event.TypedUpdateEvent[*corev1.LimitRange], ...) + type PodGroupRuntimeClassHandler struct + func (h *PodGroupRuntimeClassHandler) Create(ctx context.Context, e event.TypedCreateEvent[*nodev1.RuntimeClass], ...) + func (h *PodGroupRuntimeClassHandler) Delete(ctx context.Context, e event.TypedDeleteEvent[*nodev1.RuntimeClass], ...) + func (h *PodGroupRuntimeClassHandler) Generic(context.Context, event.TypedGenericEvent[*nodev1.RuntimeClass], ...) + func (h *PodGroupRuntimeClassHandler) Update(ctx context.Context, e event.TypedUpdateEvent[*nodev1.RuntimeClass], ...)