Documentation
¶
Index ¶
- Constants
- func GetPluginName() string
- type VolcanoBatchScheduler
- func (v *VolcanoBatchScheduler) AddMetadataToChildResource(_ context.Context, parent metav1.Object, child metav1.Object, groupName string)
- func (v *VolcanoBatchScheduler) CleanupOnCompletion(ctx context.Context, object metav1.Object) (bool, error)
- func (v *VolcanoBatchScheduler) DoBatchSchedulingOnSubmission(ctx context.Context, object metav1.Object) error
- func (v *VolcanoBatchScheduler) Name() string
- type VolcanoBatchSchedulerFactory
- func (vf *VolcanoBatchSchedulerFactory) AddToScheme(scheme *runtime.Scheme)
- func (vf *VolcanoBatchSchedulerFactory) ConfigureReconciler(b *builder.Builder) *builder.Builder
- func (vf *VolcanoBatchSchedulerFactory) New(_ context.Context, _ *rest.Config, cli client.Client) (schedulerinterface.BatchScheduler, error)
Constants ¶
View Source
const ( QueueNameLabelKey = "volcano.sh/queue-name" NetworkTopologyModeLabelKey = "volcano.sh/network-topology-mode" NetworkTopologyHighestTierAllowedLabelKey = "volcano.sh/network-topology-highest-tier-allowed" )
Variables ¶
This section is empty.
Functions ¶
func GetPluginName ¶
func GetPluginName() string
Types ¶
type VolcanoBatchScheduler ¶
type VolcanoBatchScheduler struct {
// contains filtered or unexported fields
}
func (*VolcanoBatchScheduler) AddMetadataToChildResource ¶ added in v1.5.0
func (*VolcanoBatchScheduler) CleanupOnCompletion ¶ added in v1.6.0
func (v *VolcanoBatchScheduler) CleanupOnCompletion(ctx context.Context, object metav1.Object) (bool, error)
CleanupOnCompletion recalculates and updates the PodGroup resources when a RayJob finishes. This is called when the RayJob reaches terminal state (Complete/Failed).
For RayCluster objects, this is a no-op because the PodGroup is cleaned up by the OwnerReference of the RayCluster.
For RayJob objects, the PodGroup's MinMember and MinResources are recalculated based on the live RayCluster state. This correctly handles deletion strategies:
- If workers are suspended by DeleteWorkers policy, calculatePodGroupParams automatically excludes suspended groups, so the PodGroup reflects only the head pod.
- If the RayCluster is deleted by DeleteCluster or ShutdownAfterJobFinishes, the PodGroup is updated with empty resources.
func (*VolcanoBatchScheduler) DoBatchSchedulingOnSubmission ¶
func (*VolcanoBatchScheduler) Name ¶
func (v *VolcanoBatchScheduler) Name() string
type VolcanoBatchSchedulerFactory ¶
type VolcanoBatchSchedulerFactory struct{}
func (*VolcanoBatchSchedulerFactory) AddToScheme ¶
func (vf *VolcanoBatchSchedulerFactory) AddToScheme(scheme *runtime.Scheme)
func (*VolcanoBatchSchedulerFactory) ConfigureReconciler ¶
func (vf *VolcanoBatchSchedulerFactory) ConfigureReconciler(b *builder.Builder) *builder.Builder
func (*VolcanoBatchSchedulerFactory) New ¶
func (vf *VolcanoBatchSchedulerFactory) New(_ context.Context, _ *rest.Config, cli client.Client) (schedulerinterface.BatchScheduler, error)
Source Files
Click to show internal directories.
Click to hide internal directories.