solvers

Documentation

Index

• type GenerateVictimsQueue
• type JobSolver
  • func NewJobsSolver(feasibleNodes []*node_info.NodeInfo, solutionValidator SolutionValidator, ...) *JobSolver
  • func (s *JobSolver) Solve(ssn *framework.Session, pendingJob *podgroup_info.PodGroupInfo) (bool, *framework.Statement, []string)
• type PodAccumulatedScenarioBuilder
  • func NewPodAccumulatedScenarioBuilder(session *framework.Session, pendingJob *podgroup_info.PodGroupInfo, ...) *PodAccumulatedScenarioBuilder
  • func (asb *PodAccumulatedScenarioBuilder) GetNextScenario() *solverscenario.ByNodeScenario
  • func (asb *PodAccumulatedScenarioBuilder) GetValidScenario() *solverscenario.ByNodeScenario
• type SolutionValidator

Types

type GenerateVictimsQueue

type GenerateVictimsQueue func() *utils.JobsOrderByQueues

type JobSolver

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

func NewJobsSolver

func NewJobsSolver(
	feasibleNodes []*node_info.NodeInfo,
	solutionValidator SolutionValidator,
	generateVictimsQueue GenerateVictimsQueue,
	action framework.ActionType,
) *JobSolver

func (*JobSolver) Solve

func (s *JobSolver) Solve(
	ssn *framework.Session, pendingJob *podgroup_info.PodGroupInfo) (bool, *framework.Statement, []string)

type PodAccumulatedScenarioBuilder

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

func NewPodAccumulatedScenarioBuilder

func NewPodAccumulatedScenarioBuilder(
	session *framework.Session, pendingJob *podgroup_info.PodGroupInfo, recordedVictimsJobs []*podgroup_info.PodGroupInfo,
	victimsJobsQueue *utils.JobsOrderByQueues, feasibleNodes map[string]*node_info.NodeInfo,
) *PodAccumulatedScenarioBuilder

func (*PodAccumulatedScenarioBuilder) GetNextScenario

func (asb *PodAccumulatedScenarioBuilder) GetNextScenario() *solverscenario.ByNodeScenario

func (*PodAccumulatedScenarioBuilder) GetValidScenario

func (asb *PodAccumulatedScenarioBuilder) GetValidScenario() *solverscenario.ByNodeScenario

type SolutionValidator

type SolutionValidator func(scenario api.ScenarioInfo) bool