complexscheduler

Documentation

Index

• func AveragePlan(nodesInfo []types.NodeInfo, need int) ([]types.NodeInfo, error)
• func CommunismDivisionPlan(arg []types.NodeInfo, need int) ([]types.NodeInfo, error)
• func FillPlan(nodesInfo []types.NodeInfo, need int) ([]types.NodeInfo, error)
• type Potassium
  • func New(config types.Config) (*Potassium, error)
  • func (m *Potassium) CommonDivision(nodesInfo []types.NodeInfo, need, total int) ([]types.NodeInfo, error)
  • func (m *Potassium) EachDivision(nodesInfo []types.NodeInfo, need, total int) ([]types.NodeInfo, error)
  • func (m *Potassium) FillDivision(nodesInfo []types.NodeInfo, need, total int) ([]types.NodeInfo, error)
  • func (m *Potassium) MaxCPUIdleNode(nodes []*types.Node) *types.Node
  • func (m *Potassium) SelectCPUNodes(nodesInfo []types.NodeInfo, quota float64, memory int64) ([]types.NodeInfo, map[string][]types.CPUMap, int, error)
  • func (m *Potassium) SelectMemoryNodes(nodesInfo []types.NodeInfo, quota float64, memory int64) ([]types.NodeInfo, int, error)

Functions

func AveragePlan

func AveragePlan(nodesInfo []types.NodeInfo, need int) ([]types.NodeInfo, error)

AveragePlan deploy container each node

func CommunismDivisionPlan

func CommunismDivisionPlan(arg []types.NodeInfo, need int) ([]types.NodeInfo, error)

CommunismDivisionPlan 吃我一记共产主义大锅饭

func FillPlan

func FillPlan(nodesInfo []types.NodeInfo, need int) ([]types.NodeInfo, error)

FillPlan deploy container each node

Types

type Potassium

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

Potassium is a scheduler

func New

func New(config types.Config) (*Potassium, error)

New a potassium

func (*Potassium) CommonDivision

func (m *Potassium) CommonDivision(nodesInfo []types.NodeInfo, need, total int) ([]types.NodeInfo, error)

CommonDivision deploy containers by their deploy status 部署完 N 个后全局尽可能平均

func (*Potassium) EachDivision

func (m *Potassium) EachDivision(nodesInfo []types.NodeInfo, need, total int) ([]types.NodeInfo, error)

EachDivision deploy containers by each node 容量够的机器每一台部署 N 个

func (*Potassium) FillDivision

func (m *Potassium) FillDivision(nodesInfo []types.NodeInfo, need, total int) ([]types.NodeInfo, error)

FillDivision deploy containers fill nodes by count 根据之前部署的策略每一台补充到 N 个，超过 N 个忽略

func (*Potassium) MaxCPUIdleNode

func (m *Potassium) MaxCPUIdleNode(nodes []*types.Node) *types.Node

MaxCPUIdleNode use for build

func (*Potassium) SelectCPUNodes

func (m *Potassium) SelectCPUNodes(nodesInfo []types.NodeInfo, quota float64, memory int64) ([]types.NodeInfo, map[string][]types.CPUMap, int, error)

SelectCPUNodes select nodes with enough cpus

func (*Potassium) SelectMemoryNodes

func (m *Potassium) SelectMemoryNodes(nodesInfo []types.NodeInfo, quota float64, memory int64) ([]types.NodeInfo, int, error)

SelectMemoryNodes filter nodes with enough memory