fairness

Documentation

Index

• type DominantResourceFairness
  • func NewDominantResourceFairness(totalResources schedulerobjects.ResourceList, ...) (*DominantResourceFairness, error)
  • func (f *DominantResourceFairness) UnweightedCostFromAllocation(allocation schedulerobjects.ResourceList) float64
  • func (f *DominantResourceFairness) UnweightedCostFromQueue(queue Queue) float64
  • func (f *DominantResourceFairness) WeightedCostFromAllocation(allocation schedulerobjects.ResourceList, weight float64) float64
  • func (f *DominantResourceFairness) WeightedCostFromQueue(queue Queue) float64
• type FairnessCostProvider
• type Queue
• type QueueRepository

Types

type DominantResourceFairness

type DominantResourceFairness struct {
	// contains filtered or unexported fields
}

func NewDominantResourceFairness

func NewDominantResourceFairness(totalResources schedulerobjects.ResourceList, config configuration.SchedulingConfig) (*DominantResourceFairness, error)

func (*DominantResourceFairness) UnweightedCostFromAllocation

func (f *DominantResourceFairness) UnweightedCostFromAllocation(allocation schedulerobjects.ResourceList) float64

func (*DominantResourceFairness) UnweightedCostFromQueue

func (f *DominantResourceFairness) UnweightedCostFromQueue(queue Queue) float64

func (*DominantResourceFairness) WeightedCostFromAllocation

func (f *DominantResourceFairness) WeightedCostFromAllocation(allocation schedulerobjects.ResourceList, weight float64) float64

func (*DominantResourceFairness) WeightedCostFromQueue

func (f *DominantResourceFairness) WeightedCostFromQueue(queue Queue) float64

type FairnessCostProvider

type FairnessCostProvider interface {
	UnweightedCostFromQueue(queue Queue) float64
	UnweightedCostFromAllocation(allocation schedulerobjects.ResourceList) float64
	WeightedCostFromQueue(queue Queue) float64
	WeightedCostFromAllocation(allocation schedulerobjects.ResourceList, weight float64) float64
}

FairnessCostProvider captures algorithms to compute the cost of an allocation.

type Queue

type Queue interface {
	// GetAllocation returns the current allocation of the queue.
	GetAllocation() schedulerobjects.ResourceList
	GetWeight() float64
}

Queue is a minimal representation of a queue used for computing fairness.

type QueueRepository

type QueueRepository interface {
	GetQueue(name string) (Queue, bool)
}

QueueRepository is a minimal representation of a queue repository used for computing fairness.