routerconcurrency

Documentation

Index

• func GetLimiter() *rcLimiter
• func InitLimiter(routers []elton.RouterInfo)
• func List() map[string]uint32
• func Update(arr []string)
• type RouterConcurrency
  • func (rc *RouterConcurrency) Take()

Functions

func GetLimiter

func GetLimiter() *rcLimiter

GetLimiter 获取路由并发限制器

func InitLimiter

func InitLimiter(routers []elton.RouterInfo)

InitLimiter 初始路由并发限制

func List

func List() map[string]uint32

List 获取路由并发限制数

func Update

func Update(arr []string)

Update 更新路由并发数

Types

type RouterConcurrency

type RouterConcurrency struct {
	Router string `json:"router"`
	Max    uint32 `json:"max"`
	// 频率限制
	Rate int `json:"rate"`
	// 间隔
	Interval string `json:"interval"`
	// contains filtered or unexported fields
}

RouterConcurrency 路由并发配置

func (*RouterConcurrency) Take

func (rc *RouterConcurrency) Take()

Take 执行一次频率限制，此执行会根据当时频率延时