Documentation
¶
Overview ¶
TODO(all) - implement score for macroservice. - implement filter/score for socket service. - implement filter/score for GPU service.
Index ¶
- func AvailableToPercentage(clusterAvailables map[string]corev1.ResourceList, ...) (clusterWeights map[string]int64, err error)
- func CalcWeightLimit(clusters []*fedcorev1a1.FederatedCluster, resourceName corev1.ResourceName, ...) (weightLimit map[string]int64, err error)
- func NewClusterCapacityWeight(frameworkHandle framework.Handle) (framework.Plugin, error)
- func QueryAllocatable(clusters []*fedcorev1a1.FederatedCluster) map[string]corev1.ResourceList
- func QueryAvailable(clusters []*fedcorev1a1.FederatedCluster) map[string]corev1.ResourceList
- func QueryClusterResource(clusters []*fedcorev1a1.FederatedCluster, resource string) map[string]corev1.ResourceList
- type ClusterCapacityWeight
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AvailableToPercentage ¶
func AvailableToPercentage( clusterAvailables map[string]corev1.ResourceList, resourceName corev1.ResourceName, weightLimit map[string]int64, ) (clusterWeights map[string]int64, err error)
func CalcWeightLimit ¶
func CalcWeightLimit( clusters []*fedcorev1a1.FederatedCluster, resourceName corev1.ResourceName, supplyLimitRatio float64, ) (weightLimit map[string]int64, err error)
func QueryAllocatable ¶
func QueryAllocatable(clusters []*fedcorev1a1.FederatedCluster) map[string]corev1.ResourceList
QueryAllocatable aggregate cluster allocatable resource.
func QueryAvailable ¶
func QueryAvailable(clusters []*fedcorev1a1.FederatedCluster) map[string]corev1.ResourceList
QueryAvailable aggregate cluster available resource.
func QueryClusterResource ¶
func QueryClusterResource(clusters []*fedcorev1a1.FederatedCluster, resource string) map[string]corev1.ResourceList
QueryClusterResource aggregate cluster resources, accept available and allocatable.
Types ¶
type ClusterCapacityWeight ¶
type ClusterCapacityWeight struct{}
func (*ClusterCapacityWeight) Name ¶
func (pl *ClusterCapacityWeight) Name() string
func (*ClusterCapacityWeight) ReplicaScheduling ¶
func (pl *ClusterCapacityWeight) ReplicaScheduling( ctx context.Context, su *framework.SchedulingUnit, clusters []*fedcorev1a1.FederatedCluster, ) (framework.ClusterReplicasList, *framework.Result)
Source Files
Click to show internal directories.
Click to hide internal directories.