Documentation
¶
Index ¶
Constants ¶
View Source
const ( SchedulerName string = "yunikorn" YuniKornPodApplicationIDLabelName string = "applicationId" YuniKornPodQueueLabelName string = "queue" RayApplicationIDLabelName string = "yunikorn.apache.org/app-id" RayApplicationQueueLabelName string = "yunikorn.apache.org/queue" YuniKornTaskGroupNameAnnotationName string = "yunikorn.apache.org/task-group-name" YuniKornTaskGroupsAnnotationName string = "yunikorn.apache.org/task-groups" )
Variables ¶
This section is empty.
Functions ¶
func GetPluginName ¶
func GetPluginName() string
Types ¶
type TaskGroup ¶ added in v1.2.2
type TaskGroup struct {
MinResource map[string]resource.Quantity `json:"minResource"`
NodeSelector map[string]string `json:"nodeSelector,omitempty"`
Affinity *corev1.Affinity `json:"affinity,omitempty"`
Name string `json:"name"`
TopologySpreadConstraints []corev1.TopologySpreadConstraint `json:"topologySpreadConstraints,omitempty"`
Tolerations []corev1.Toleration `json:"tolerations,omitempty"`
MinMember int32 `json:"minMember"`
}
TaskGroup is the struct for yunikorn to consider a pod belongs to a gang group the original schema is defined here: https://github.com/apache/yunikorn-k8shim/blob/master/pkg/cache/amprotocol.go
type TaskGroups ¶ added in v1.2.2
type TaskGroups struct {
Groups []TaskGroup `json:"groups"`
}
TaskGroups is a list of task Groups recognized as gang Groups
type YuniKornScheduler ¶
type YuniKornScheduler struct{}
func (*YuniKornScheduler) AddMetadataToChildResource ¶ added in v1.5.0
func (*YuniKornScheduler) DoBatchSchedulingOnSubmission ¶
func (*YuniKornScheduler) Name ¶
func (y *YuniKornScheduler) Name() string
type YuniKornSchedulerFactory ¶
type YuniKornSchedulerFactory struct{}
func (*YuniKornSchedulerFactory) AddToScheme ¶
func (yf *YuniKornSchedulerFactory) AddToScheme(_ *runtime.Scheme)
func (*YuniKornSchedulerFactory) ConfigureReconciler ¶
func (yf *YuniKornSchedulerFactory) ConfigureReconciler(b *builder.Builder) *builder.Builder
func (*YuniKornSchedulerFactory) New ¶
func (yf *YuniKornSchedulerFactory) New(_ context.Context, _ *rest.Config, _ client.Client) (schedulerinterface.BatchScheduler, error)
Source Files
Click to show internal directories.
Click to hide internal directories.