placement

Documentation

Index

• func NewNodeState(name string, slots int) *nodeState
• type PlacementManager
  • func NewPlacementManager(id string, kConfig *rest.Config, resume bool) (*PlacementManager, error)
  • func (pm *PlacementManager) Place(jobRequests types.JobScheduleResult)
  • func (pm *PlacementManager) Run(stopCh <-chan struct{})
• type PlacementManagerMetrics

Functions

func NewNodeState

func NewNodeState(name string, slots int) *nodeState

NewNodeState creates a new nodeState.

Types

type PlacementManager

type PlacementManager struct {
	SchedulerID string

	StopCh chan struct{}
	// contains filtered or unexported fields
}

func NewPlacementManager

func NewPlacementManager(id string, kConfig *rest.Config, resume bool) (*PlacementManager, error)

NewPlacementManager creates a new placement manager.

func (*PlacementManager) Place

func (pm *PlacementManager) Place(jobRequests types.JobScheduleResult)

func (*PlacementManager) Run

func (pm *PlacementManager) Run(stopCh <-chan struct{})

type PlacementManagerMetrics

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