rsp

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
  • func (pl *ClusterCapacityWeight) Name() string
  • func (pl *ClusterCapacityWeight) ReplicaScheduling(ctx context.Context, su *framework.SchedulingUnit, ...) (framework.ClusterReplicasList, *framework.Result)

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 NewClusterCapacityWeight

func NewClusterCapacityWeight(frameworkHandle framework.Handle) (framework.Plugin, 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)