algorithm

Aug 20, 2020

Changes in this version

type Cell

+ GetTotalLeafCellNum func() int32

+ GetUsedLeafCellNumAtPriorities func() map[CellPriority]int32

+ IncreaseUsedLeafCellNumAtPriority func(CellPriority, int32)

type GenericCell

+ func (c *GenericCell) GetTotalLeafCellNum() int32

+ func (c *GenericCell) GetUsedLeafCellNumAtPriorities() map[CellPriority]int32

+ func (c *GenericCell) IncreaseUsedLeafCellNumAtPriority(p CellPriority, delta int32)

Jul 2, 2020

Changes in this version

type GenericCell

+ func (c *GenericCell) IsHealthy() bool

type PhysicalCell

+ func (c *PhysicalCell) AddReservingOrReservedGroup(g *AlgoAffinityGroup)

+ func (c *PhysicalCell) DeleteReservingOrReservedGroup(g *AlgoAffinityGroup)

+ func (c *PhysicalCell) GetReservingOrReservedGroup() *AlgoAffinityGroup

+ func (c *PhysicalCell) IsPinned() bool

+ func (c *PhysicalCell) SetPinned(pinned bool)

type VirtualCell

+ func (c *VirtualCell) GetPreassignedCell() *VirtualCell

+ func (c *VirtualCell) GetVirtualCluster() api.VirtualClusterName

+ func (c *VirtualCell) SetPinnedCellId(pid api.PinnedCellId)

Mar 30, 2020

Changes in this version

+ type AffinityGroupState string

+ type CellState string

type GenericCell

+ func (c *GenericCell) GetState() CellState

type PhysicalCell

+ func (c *PhysicalCell) AddAcquiringGroup(g *AlgoAffinityGroup)

+ func (c *PhysicalCell) AddUsingGroup(g *AlgoAffinityGroup)

+ func (c *PhysicalCell) DeleteAcquiringGroup(g *AlgoAffinityGroup)

+ func (c *PhysicalCell) DeleteUsingGroup(g *AlgoAffinityGroup)

+ func (c *PhysicalCell) GetAcquiringGroup() *AlgoAffinityGroup

+ func (c *PhysicalCell) GetUsingGroup() *AlgoAffinityGroup

+ func (c *PhysicalCell) SetHealthiness(h api.CellHealthiness)

+ func (c *PhysicalCell) SetState(s CellState)

Mar 24, 2020

Changes in this version

type Cell

+ GetAddress func() api.CellAddress

type GenericCell

+ func (c *GenericCell) GetAddress() api.CellAddress

type HivedAlgorithm

+ func (h *HivedAlgorithm) AddUnallocatedPod(pod *core.Pod)

+ func (h *HivedAlgorithm) DeleteUnallocatedPod(pod *core.Pod)

+ func (h *HivedAlgorithm) GetAllAffinityGroups() api.AffinityGroupList

+ func (h *HivedAlgorithm) GetAllVirtualClustersStatus() map[api.VirtualClusterName]api.VirtualClusterStatus

+ func (h *HivedAlgorithm) GetClusterStatus() api.ClusterStatus

+ func (h *HivedAlgorithm) GetPhysicalClusterStatus() api.PhysicalClusterStatus

+ func (h *HivedAlgorithm) GetVirtualClusterStatus(vcn api.VirtualClusterName) api.VirtualClusterStatus

type PhysicalCell

+ func (c *PhysicalCell) GetAPIStatus() *api.PhysicalCellStatus

+ func (c *PhysicalCell) SetChildren(children CellList)

+ func (c *PhysicalCell) SetPriority(p CellPriority)

type VirtualCell

+ func (c *VirtualCell) GetAPIStatus() *api.VirtualCellStatus

+ func (c *VirtualCell) SetChildren(children CellList)

+ func (c *VirtualCell) SetPriority(p CellPriority)

Dec 6, 2019

Changes in this version

type AlgoAffinityGroup

+ func (aag *AlgoAffinityGroup) ToAffinityGroup() api.AffinityGroup

type HivedAlgorithm

+ func (h *HivedAlgorithm) GetAffinityGroup(name string) api.AffinityGroup

+ func (h *HivedAlgorithm) GetAffinityGroups() api.AffinityGroupList

Nov 4, 2019

Changes in this version

+ func CellEqual(c1 Cell, c2 Cell) bool

+ func NewTopologyAwareScheduler(ccl ChainCellList, levelGpuNum map[CellLevel]int32, crossPriorityPack bool, ...) *topologyAwareScheduler

type Cell

+ AtOrHigherThanNode func() bool

+ GetTotalGpuNum func() int32

+ GetUsedGpuNumAtPriorities func() map[CellPriority]int32

+ IncreaseUsedGpuNumAtPriority func(CellPriority, int32)

type GenericCell

+ func (c *GenericCell) AtOrHigherThanNode() bool

+ func (c *GenericCell) GetTotalGpuNum() int32

+ func (c *GenericCell) GetUsedGpuNumAtPriorities() map[CellPriority]int32

+ func (c *GenericCell) IncreaseUsedGpuNumAtPriority(p CellPriority, delta int32)

type PhysicalCell

+ func (c *PhysicalCell) AddAffinityGroup(g *AlgoAffinityGroup)

+ func (c *PhysicalCell) DeleteAffinityGroup(g *AlgoAffinityGroup)

+ func (c *PhysicalCell) GetAffinityGroup() *AlgoAffinityGroup

+ func (c *PhysicalCell) GetPreBoundVirtualCell() *VirtualCell

+ func (c *PhysicalCell) IsSplit() bool

+ func (c *PhysicalCell) SetPreBoundVirtualCell(vc *VirtualCell)

+ func (c *PhysicalCell) SetSplit(split bool)

type VirtualCell

+ func (c *VirtualCell) GetPreBoundPhysicalCell() *PhysicalCell

+ func (c *VirtualCell) SetPreBoundPhysicalCell(pc *PhysicalCell)

Aug 2, 2019

Changes in this version

+ func ParseConfig(sConfig *api.Config) (map[CellChain]ChainCellList, map[CellChain]map[CellLevel]int32, ...)

+ type AlgoAffinityGroup struct

+ type Cell interface

+ GetChain func() CellChain

+ GetChildren func() CellList

+ GetLevel func() CellLevel

+ GetName func() string

+ GetParent func() Cell

+ GetPriority func() CellPriority

+ SetChildren func(CellList)

+ SetParent func(Cell)

+ SetPriority func(CellPriority)

+ type CellChain string

+ type CellLevel int32

+ type CellList []Cell

+ func (cl CellList) String() string

+ type CellPriority int32

+ type CellRequest struct

+ Chain CellChain

+ Level CellLevel

+ Priority CellPriority

+ ReservationId api.ReservationId

+ VC api.VirtualClusterName

+ type ChainCellList map[CellLevel]CellList

+ func NewChainCellList(top CellLevel) ChainCellList

+ func (ccl ChainCellList) String() string

+ type GenericCell struct

+ func (c *GenericCell) GetChain() CellChain

+ func (c *GenericCell) GetChildren() CellList

+ func (c *GenericCell) GetLevel() CellLevel

+ func (c *GenericCell) GetParent() Cell

+ func (c *GenericCell) GetPriority() CellPriority

+ func (c *GenericCell) SetChildren(children CellList)

+ func (c *GenericCell) SetParent(p Cell)

+ func (c *GenericCell) SetPriority(p CellPriority)

+ type HivedAlgorithm struct

+ func NewHivedAlgorithm(sConfig *api.Config) *HivedAlgorithm

+ func (h *HivedAlgorithm) AddAllocatedPod(pod *core.Pod)

+ func (h *HivedAlgorithm) AddNode(node *core.Node)

+ func (h *HivedAlgorithm) DeleteAllocatedPod(pod *core.Pod)

+ func (h *HivedAlgorithm) DeleteNode(node *core.Node)

+ func (h *HivedAlgorithm) Schedule(pod *core.Pod, suggestedNodes []string) internal.PodScheduleResult

+ func (h *HivedAlgorithm) UpdateNode(oldNode, newNode *core.Node)

+ type PhysicalCell struct

+ func NewPhysicalCell(c CellChain, l CellLevel) *PhysicalCell

+ func (c *PhysicalCell) AddPod(pod types.UID)

+ func (c *PhysicalCell) ClearPhysicalCellList()

+ func (c *PhysicalCell) DeletePod(pod types.UID)

+ func (c *PhysicalCell) GetName() string

+ func (c *PhysicalCell) GetPhysicalCellList() ChainCellList

+ func (c *PhysicalCell) GetPhysicalPlacement() ([]string, []int32)

+ func (c *PhysicalCell) GetPhysicalPlacementString() string

+ func (c *PhysicalCell) GetVirtualCell() *VirtualCell

+ func (c *PhysicalCell) HasPod() bool

+ func (c *PhysicalCell) InitPhysicalCellList()

+ func (c *PhysicalCell) IsReserved() bool

+ func (c *PhysicalCell) SetPhysicalResources(nodes []string, gpuIndices []int32)

+ func (c *PhysicalCell) SetReserved(reserved bool)

+ func (c *PhysicalCell) SetVirtualCell(vc *VirtualCell)

+ type VirtualCell struct

+ func NewVirtualCell(vc api.VirtualClusterName, c CellChain, l CellLevel, i int32, pac *VirtualCell) *VirtualCell

+ func (c *VirtualCell) GetIndex() int32

+ func (c *VirtualCell) GetName() string

+ func (c *VirtualCell) GetPhysicalCell() *PhysicalCell

+ func (c *VirtualCell) GetPreAssignedCell() *VirtualCell

+ func (c *VirtualCell) SetIndex(i int32)

+ func (c *VirtualCell) SetPhysicalCell(pc *PhysicalCell)

+ func (c *VirtualCell) SetPreAssignedCell(vc *VirtualCell)

+ func (c *VirtualCell) SetReservation(rid api.ReservationId)