strategy

package

v0.0.0-...-06bcc1c Latest Latest Go to latest Published: Mar 21, 2024 License: MIT Imports: 7 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/projecteru2/core

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AveragePlan(ctx context.Context, infos []Info, need, _, limit int) (map[string]int, error)
func CommunismPlan(_ context.Context, infos []Info, need, total, limit int) (map[string]int, error)
func Deploy(ctx context.Context, strategy string, count, nodesLimit int, ...) (map[string]int, error)
func DrainedPlan(_ context.Context, infos []Info, need, total, _ int) (map[string]int, error)
func FillPlan(ctx context.Context, infos []Info, need, _, limit int) (_ map[string]int, err error)
func GlobalPlan(ctx context.Context, infos []Info, need, total, _ int) (map[string]int, error)
type Info

Constants ¶

View Source

const (
	// Auto .
	Auto = "AUTO"
	// Fill .
	Fill = "FILL"
	// Each .
	Each = "EACH"
	// Global .
	Global = "GLOBAL"
	// Drained .
	Drained = "DRAINED"
	// Dummy for calculate capacity
	Dummy = "DUMMY"
)

Variables ¶

View Source

var Plans = map[string]strategyFunc{
	Auto:    CommunismPlan,
	Fill:    FillPlan,
	Each:    AveragePlan,
	Global:  GlobalPlan,
	Drained: DrainedPlan,
}

Plans .

Functions ¶

func AveragePlan ¶

func AveragePlan(ctx context.Context, infos []Info, need, _, limit int) (map[string]int, error)

AveragePlan deploy workload each node 容量够的机器每一台部署 N 个 need 是每台机器所需总量，limit 是限制节点数, 保证本轮增量部署 need*limit 个实例 limit = 0 即对所有节点部署

func CommunismPlan ¶

func CommunismPlan(_ context.Context, infos []Info, need, total, limit int) (map[string]int, error)

CommunismPlan 吃我一记共产主义大锅饭部署完 N 个后全局尽可能平均

func Deploy ¶

func Deploy(ctx context.Context, strategy string, count, nodesLimit int, strategyInfos []Info, total int) (map[string]int, error)

Deploy .

func DrainedPlan ¶

func DrainedPlan(_ context.Context, infos []Info, need, total, _ int) (map[string]int, error)

DrainedPlan 优先往Capacity最小的节点部署，尽可能把节点的资源榨干在部署下一台.

func FillPlan ¶

func FillPlan(ctx context.Context, infos []Info, need, _, limit int) (_ map[string]int, err error)

FillPlan deploy workload each node 根据之前部署的策略每一台补充到 N 个，已经超过 N 个的节点视为已满足 need 是每台上限, limit 是限制节点数, 保证最终状态至少有 limit*need 个实例 limit = 0 代表对所有节点进行填充

func GlobalPlan ¶

func GlobalPlan(ctx context.Context, infos []Info, need, total, _ int) (map[string]int, error)

GlobalPlan 基于全局资源配额尽量使得资源消耗平均

Types ¶

type Info ¶

type Info struct {
	Nodename string

	Usage float64
	Rate  float64

	Capacity int
	Count    int
}

Info .

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL