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