migstate

Documentation

Index

• func FromMigNodeToNodePartitioning(node mig.Node) state.NodePartitioning
• type MigClusterSnapshot
  • func NewClusterSnapshot(snapshot state.ClusterSnapshot) (MigClusterSnapshot, error)
  • func (s *MigClusterSnapshot) AddPod(nodeName string, pod v1.Pod) error
  • func (s *MigClusterSnapshot) Commit()
  • func (s *MigClusterSnapshot) Fork() error
  • func (s *MigClusterSnapshot) GetCandidateNodes() []mig.Node
  • func (s *MigClusterSnapshot) GetLackingMigProfiles(pod v1.Pod) map[mig.ProfileName]int
  • func (s *MigClusterSnapshot) GetPartitioningState() state.PartitioningState
  • func (s *MigClusterSnapshot) SetNode(node mig.Node) error

Functions

func FromMigNodeToNodePartitioning

func FromMigNodeToNodePartitioning(node mig.Node) state.NodePartitioning

Types

type MigClusterSnapshot

type MigClusterSnapshot struct {
	state.ClusterSnapshot
	// contains filtered or unexported fields
}

func NewClusterSnapshot

func NewClusterSnapshot(snapshot state.ClusterSnapshot) (MigClusterSnapshot, error)

func (*MigClusterSnapshot) AddPod

func (s *MigClusterSnapshot) AddPod(nodeName string, pod v1.Pod) error

func (*MigClusterSnapshot) Commit

func (s *MigClusterSnapshot) Commit()

func (*MigClusterSnapshot) Fork

func (s *MigClusterSnapshot) Fork() error

func (*MigClusterSnapshot) GetCandidateNodes

func (s *MigClusterSnapshot) GetCandidateNodes() []mig.Node

GetCandidateNodes returns the Nodes with free MIG devices or available MIG capacity

func (*MigClusterSnapshot) GetLackingMigProfiles

func (s *MigClusterSnapshot) GetLackingMigProfiles(pod v1.Pod) map[mig.ProfileName]int

GetLackingMigProfiles returns (if any) the name and the quantity of the MIG profiles requested by the Pod but currently not available in the ClusterSnapshot.

func (*MigClusterSnapshot) GetPartitioningState

func (s *MigClusterSnapshot) GetPartitioningState() state.PartitioningState

func (*MigClusterSnapshot) SetNode

func (s *MigClusterSnapshot) SetNode(node mig.Node) error