coscheduling

package

v2.0.1 Latest Latest Go to latest Published: Sep 29, 2025 License: Apache-2.0 Imports: 29 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kubeflow/trainer

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func IndexClusterTrainingRuntimeContainerRuntimeClass(obj client.Object) []string
func IndexTrainingRuntimeContainerRuntimeClass(obj client.Object) []string
func New(ctx context.Context, client client.Client, indexer client.FieldIndexer) (framework.Plugin, error)
type CoScheduling
type PodGroupLimitRangeHandler
type PodGroupRuntimeClassHandler

Constants ¶

View Source

const Name = "CoScheduling"

Variables ¶

View Source

var (
	ErrorCanNotSetupTrainingRuntimeRuntimeClassIndexer        = errors.New("setting index on runtimeClass for TrainingRuntime")
	ErrorCanNotSetupClusterTrainingRuntimeRuntimeClassIndexer = errors.New("setting index on runtimeClass for ClusterTrainingRuntime")
)

View Source

var (
	TrainingRuntimeContainerRuntimeClassKey        = ".trainingRuntimeSpec.jobSetTemplateSpec.replicatedJobs.podTemplateSpec.runtimeClassName"
	ClusterTrainingRuntimeContainerRuntimeClassKey = ".clusterTrainingRuntimeSpec.jobSetTemplateSpec.replicatedJobs.podTemplateSpec.runtimeClassName"
)

Functions ¶

func IndexClusterTrainingRuntimeContainerRuntimeClass ¶

func IndexClusterTrainingRuntimeContainerRuntimeClass(obj client.Object) []string

func IndexTrainingRuntimeContainerRuntimeClass ¶

func IndexTrainingRuntimeContainerRuntimeClass(obj client.Object) []string

func New ¶

func New(ctx context.Context, client client.Client, indexer client.FieldIndexer) (framework.Plugin, error)

Types ¶

type CoScheduling ¶

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

func (*CoScheduling) Build ¶

func (c *CoScheduling) Build(ctx context.Context, info *runtime.Info, trainJob *trainer.TrainJob) ([]any, error)

func (*CoScheduling) EnforcePodGroupPolicy ¶

func (c *CoScheduling) EnforcePodGroupPolicy(info *runtime.Info, trainJob *trainer.TrainJob) error

func (*CoScheduling) Name ¶

func (c *CoScheduling) Name() string

func (*CoScheduling) ReconcilerBuilders ¶

func (c *CoScheduling) ReconcilerBuilders() []runtime.ReconcilerBuilder

type PodGroupLimitRangeHandler ¶

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

func (*PodGroupLimitRangeHandler) Create ¶

func (h *PodGroupLimitRangeHandler) Create(ctx context.Context, e event.TypedCreateEvent[*corev1.LimitRange], q workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*PodGroupLimitRangeHandler) Delete ¶

func (h *PodGroupLimitRangeHandler) Delete(ctx context.Context, e event.TypedDeleteEvent[*corev1.LimitRange], q workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*PodGroupLimitRangeHandler) Generic ¶

func (h *PodGroupLimitRangeHandler) Generic(context.Context, event.TypedGenericEvent[*corev1.LimitRange], workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*PodGroupLimitRangeHandler) Update ¶

func (h *PodGroupLimitRangeHandler) Update(ctx context.Context, e event.TypedUpdateEvent[*corev1.LimitRange], q workqueue.TypedRateLimitingInterface[reconcile.Request])

type PodGroupRuntimeClassHandler ¶

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

func (*PodGroupRuntimeClassHandler) Create ¶

func (h *PodGroupRuntimeClassHandler) Create(ctx context.Context, e event.TypedCreateEvent[*nodev1.RuntimeClass], q workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*PodGroupRuntimeClassHandler) Delete ¶

func (h *PodGroupRuntimeClassHandler) Delete(ctx context.Context, e event.TypedDeleteEvent[*nodev1.RuntimeClass], q workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*PodGroupRuntimeClassHandler) Generic ¶

func (h *PodGroupRuntimeClassHandler) Generic(context.Context, event.TypedGenericEvent[*nodev1.RuntimeClass], workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*PodGroupRuntimeClassHandler) Update ¶

func (h *PodGroupRuntimeClassHandler) Update(ctx context.Context, e event.TypedUpdateEvent[*nodev1.RuntimeClass], q workqueue.TypedRateLimitingInterface[reconcile.Request])

Source Files ¶

View all Source files

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