scenario

Documentation

Index

• type BaseScenario
  • func NewBaseScenario(session *framework.Session, ...) *BaseScenario
  • func (s *BaseScenario) AddPotentialVictimsTasks(tasks []*pod_info.PodInfo)
  • func (s *BaseScenario) GetPreemptor() *podgroup_info.PodGroupInfo
  • func (s *BaseScenario) GetVictimJobRepresentativeById(victimPodInfo *pod_info.PodInfo) *podgroup_info.PodGroupInfo
  • func (s *BaseScenario) GetVictims() map[common_info.PodGroupID]*api.VictimInfo
  • func (s *BaseScenario) LatestPotentialVictim() *podgroup_info.PodGroupInfo
  • func (s *BaseScenario) PendingTasks() []*pod_info.PodInfo
  • func (s *BaseScenario) PotentialVictimsTasks() []*pod_info.PodInfo
  • func (s *BaseScenario) RecordedVictimsJobs() []*podgroup_info.PodGroupInfo
  • func (s *BaseScenario) RecordedVictimsTasks() []*pod_info.PodInfo
  • func (s *BaseScenario) String() string
• type ByNodeScenario
  • func NewByNodeScenario(session *framework.Session, ...) *ByNodeScenario
  • func (bns *ByNodeScenario) AddPotentialVictimsTasks(tasks []*pod_info.PodInfo)
  • func (bns *ByNodeScenario) VictimsTasksFromNodes(nodeNames []string) []*pod_info.PodInfo

Types

type BaseScenario

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

func NewBaseScenario

func NewBaseScenario(
	session *framework.Session, originalJob, pendingTasksAsJob *podgroup_info.PodGroupInfo, victimsTasks []*pod_info.PodInfo,
	recordedVictimsJobs []*podgroup_info.PodGroupInfo,
) *BaseScenario

func (*BaseScenario) AddPotentialVictimsTasks

func (s *BaseScenario) AddPotentialVictimsTasks(tasks []*pod_info.PodInfo)

func (*BaseScenario) GetPreemptor

func (s *BaseScenario) GetPreemptor() *podgroup_info.PodGroupInfo

func (*BaseScenario) GetVictimJobRepresentativeById

func (s *BaseScenario) GetVictimJobRepresentativeById(victimPodInfo *pod_info.PodInfo) *podgroup_info.PodGroupInfo

func (*BaseScenario) GetVictims

func (s *BaseScenario) GetVictims() map[common_info.PodGroupID]*api.VictimInfo

func (*BaseScenario) LatestPotentialVictim

func (s *BaseScenario) LatestPotentialVictim() *podgroup_info.PodGroupInfo

func (*BaseScenario) PendingTasks

func (s *BaseScenario) PendingTasks() []*pod_info.PodInfo

Deprecated: Use GetPreemptor instead

func (*BaseScenario) PotentialVictimsTasks

func (s *BaseScenario) PotentialVictimsTasks() []*pod_info.PodInfo

func (*BaseScenario) RecordedVictimsJobs

func (s *BaseScenario) RecordedVictimsJobs() []*podgroup_info.PodGroupInfo

func (*BaseScenario) RecordedVictimsTasks

func (s *BaseScenario) RecordedVictimsTasks() []*pod_info.PodInfo

func (*BaseScenario) String

func (s *BaseScenario) String() string

type ByNodeScenario

type ByNodeScenario struct {
	*BaseScenario
	// contains filtered or unexported fields
}

func NewByNodeScenario

func NewByNodeScenario(
	session *framework.Session, originalJob, pendingTasksAsJob *podgroup_info.PodGroupInfo,
	potentialVictimsTasks []*pod_info.PodInfo, recordedVictimsJobs []*podgroup_info.PodGroupInfo,
) *ByNodeScenario

func (*ByNodeScenario) AddPotentialVictimsTasks

func (bns *ByNodeScenario) AddPotentialVictimsTasks(tasks []*pod_info.PodInfo)

func (*ByNodeScenario) VictimsTasksFromNodes

func (bns *ByNodeScenario) VictimsTasksFromNodes(nodeNames []string) []*pod_info.PodInfo