schedulingconfigs

Documentation

Index

• func AllSchedulingTypes() []maps.Map
• func FindSchedulingType(code string) maps.Map
• type CandidateInterface
• type HashScheduling
  • func (this *HashScheduling) Next(call *shared.RequestCall) CandidateInterface
  • func (this *HashScheduling) Start()
  • func (this *HashScheduling) Summary() maps.Map
• type RandomScheduling
  • func (this *RandomScheduling) Next(call *shared.RequestCall) CandidateInterface
  • func (this *RandomScheduling) Start()
  • func (this *RandomScheduling) Summary() maps.Map
• type RoundRobinScheduling
  • func (this *RoundRobinScheduling) Next(call *shared.RequestCall) CandidateInterface
  • func (this *RoundRobinScheduling) Start()
  • func (this *RoundRobinScheduling) Summary() maps.Map
• type Scheduling
  • func (this *Scheduling) Add(candidate ...CandidateInterface)
  • func (this *Scheduling) HasCandidates() bool
• type SchedulingInterface
• type StickyScheduling
  • func (this *StickyScheduling) Next(call *shared.RequestCall) CandidateInterface
  • func (this *StickyScheduling) Start()
  • func (this *StickyScheduling) Summary() maps.Map

Functions

func AllSchedulingTypes

func AllSchedulingTypes() []maps.Map

AllSchedulingTypes 所有请求类型

func FindSchedulingType

func FindSchedulingType(code string) maps.Map

Types

type CandidateInterface

type CandidateInterface interface {
	// CandidateWeight 权重
	CandidateWeight() uint

	// CandidateCodes 代号
	CandidateCodes() []string
}

CandidateInterface 候选对象接口

type HashScheduling

type HashScheduling struct {
	Scheduling
	// contains filtered or unexported fields
}

HashScheduling Hash调度算法

func (*HashScheduling) Next

func (this *HashScheduling) Next(call *shared.RequestCall) CandidateInterface

Next 获取下一个候选对象

func (*HashScheduling) Start

func (this *HashScheduling) Start()

Start 启动

func (*HashScheduling) Summary

func (this *HashScheduling) Summary() maps.Map

Summary 获取简要信息

type RandomScheduling

type RandomScheduling struct {
	Scheduling
	// contains filtered or unexported fields
}

RandomScheduling 随机调度算法

func (*RandomScheduling) Next

func (this *RandomScheduling) Next(call *shared.RequestCall) CandidateInterface

Next 获取下一个候选对象

func (*RandomScheduling) Start

func (this *RandomScheduling) Start()

Start 启动

func (*RandomScheduling) Summary

func (this *RandomScheduling) Summary() maps.Map

Summary 获取简要信息

type RoundRobinScheduling

type RoundRobinScheduling struct {
	Scheduling
	// contains filtered or unexported fields
}

RoundRobinScheduling 轮询调度算法

func (*RoundRobinScheduling) Next

func (this *RoundRobinScheduling) Next(call *shared.RequestCall) CandidateInterface

Next 获取下一个候选对象

func (*RoundRobinScheduling) Start

func (this *RoundRobinScheduling) Start()

Start 启动

func (*RoundRobinScheduling) Summary

func (this *RoundRobinScheduling) Summary() maps.Map

Summary 获取简要信息

type Scheduling

type Scheduling struct {
	Candidates []CandidateInterface
}

Scheduling 调度算法基础类

func (*Scheduling) Add

func (this *Scheduling) Add(candidate ...CandidateInterface)

Add 添加候选对象

func (*Scheduling) HasCandidates

func (this *Scheduling) HasCandidates() bool

HasCandidates 判断是否有候选对象

type SchedulingInterface

type SchedulingInterface interface {
	// HasCandidates 是否有候选对象
	HasCandidates() bool

	// Add 添加候选对象
	Add(candidate ...CandidateInterface)

	// Start 启动
	Start()

	// Next 查找下一个候选对象
	Next(call *shared.RequestCall) CandidateInterface

	// Summary 获取简要信息
	Summary() maps.Map
}

SchedulingInterface 调度算法接口

type StickyScheduling

type StickyScheduling struct {
	Scheduling
	// contains filtered or unexported fields
}

StickyScheduling Sticky调度算法

func (*StickyScheduling) Next

func (this *StickyScheduling) Next(call *shared.RequestCall) CandidateInterface

Next 获取下一个候选对象

func (*StickyScheduling) Start

func (this *StickyScheduling) Start()

Start 启动

func (*StickyScheduling) Summary

func (this *StickyScheduling) Summary() maps.Map

Summary 获取简要信息