scheduling

Documentation

Index

• func CalculatePriorityUpdateFromReports(reports map[string]*api.ClusterUsageReport, report *api.ClusterUsageReport, ...) map[string]float64
• func CalculateQueuesPriorityInfo(clusterPriorities map[string]map[string]float64, ...) map[*api.Queue]QueuePriorityInfo
• func FilterActiveClusters(reports map[string]*api.ClusterUsageReport, expiry time.Duration) map[string]*api.ClusterUsageReport
• func GetClusterReportIds(reports map[string]*api.ClusterUsageReport) []string
• func GetPriorityMapQueues(priorities map[*api.Queue]QueuePriorityInfo) []*api.Queue
• func ResourceScarcityFromReports(reports map[string]*api.ClusterUsageReport) map[string]float64
• func ResourcesAsUsage(resourceScarcity map[string]float64, resources common.ComputeResources) float64
• func ResourcesFloatAsUsage(resourceScarcity map[string]float64, resources common.ComputeResourcesFloat) float64
• func SliceResource(resourceScarcity map[string]float64, ...) map[*api.Queue]common.ComputeResourcesFloat
• type QueuePriorityInfo

Functions

func CalculatePriorityUpdateFromReports

func CalculatePriorityUpdateFromReports(reports map[string]*api.ClusterUsageReport, report *api.ClusterUsageReport, previousPriority map[string]float64, halfTime time.Duration) map[string]float64

func CalculateQueuesPriorityInfo

func CalculateQueuesPriorityInfo(clusterPriorities map[string]map[string]float64, activeClusterReports map[string]*api.ClusterUsageReport, queues []*api.Queue) map[*api.Queue]QueuePriorityInfo

func FilterActiveClusters

func FilterActiveClusters(reports map[string]*api.ClusterUsageReport, expiry time.Duration) map[string]*api.ClusterUsageReport

func GetClusterReportIds

func GetClusterReportIds(reports map[string]*api.ClusterUsageReport) []string

func GetPriorityMapQueues

func GetPriorityMapQueues(priorities map[*api.Queue]QueuePriorityInfo) []*api.Queue

func ResourceScarcityFromReports

func ResourceScarcityFromReports(reports map[string]*api.ClusterUsageReport) map[string]float64

func ResourcesAsUsage

func ResourcesAsUsage(resourceScarcity map[string]float64, resources common.ComputeResources) float64

func ResourcesFloatAsUsage

func ResourcesFloatAsUsage(resourceScarcity map[string]float64, resources common.ComputeResourcesFloat) float64

func SliceResource

func SliceResource(resourceScarcity map[string]float64, queuePriorities map[*api.Queue]QueuePriorityInfo, quantityToSlice common.ComputeResourcesFloat) map[*api.Queue]common.ComputeResourcesFloat

Types

type QueuePriorityInfo

type QueuePriorityInfo struct {
	Priority     float64
	CurrentUsage common.ComputeResources
}