Documentation
¶
Index ¶
- Constants
- func New(_ context.Context, client client.Client, _ client.FieldIndexer) (framework.Plugin, error)
- type CoScheduling
- func (c *CoScheduling) Build(ctx context.Context, info *runtime.Info, trainJob *trainer.TrainJob) ([]any, error)
- func (c *CoScheduling) EnforcePodGroupPolicy(info *runtime.Info, trainJob *trainer.TrainJob) error
- func (c *CoScheduling) Name() string
- func (c *CoScheduling) ReconcilerBuilders() []runtime.ReconcilerBuilder
- type PodGroupLimitRangeHandler
- 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
- 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], ...)
Constants ¶
View Source
const Name = "CoScheduling"
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CoScheduling ¶
type CoScheduling struct {
// contains filtered or unexported fields
}
func (*CoScheduling) EnforcePodGroupPolicy ¶
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
Click to show internal directories.
Click to hide internal directories.