grey_strategy

Documentation

Index

• Constants
• func Check(cfg *Config, workers map[eosc.RequireId]eosc.IWorker) error
• func Create(id, name string, v *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)
• func DoStrategy(ctx eocontext.EoContext, next eocontext.IChain) error
• func Register(register eosc.IExtenderDriverRegister)
• type ActuatorSet
• type Config
• type Controller
  • func NewController() *Controller
  • func (c *Controller) AllWorkers() []string
  • func (c *Controller) Check(cfg interface{}) (profession, name, driver, desc string, err error)
  • func (c *Controller) ConfigType() reflect.Type
  • func (c *Controller) Del(id string)
  • func (c *Controller) Get() interface{}
  • func (c *Controller) Mode() eosc.SettingMode
  • func (c *Controller) Set(conf interface{}) (err error)
  • func (c *Controller) Store(id string)
• type Grey
  • func (l *Grey) CheckSkill(skill string) bool
  • func (l *Grey) Destroy() error
  • func (l *Grey) Reset(v interface{}, workers map[eosc.RequireId]eosc.IWorker) error
  • func (l *Grey) Start() error
  • func (l *Grey) Stop() error
• type GreyBalanceHandler
  • func (g *GreyBalanceHandler) Select(ctx eocontext.EoContext) (eocontext.INode, error)
• type GreyHandler
  • func NewGreyHandler(conf *Config) (*GreyHandler, error)
• type GreyNode
  • func (g *GreyNode) Addr() string
  • func (g *GreyNode) Down()
  • func (g *GreyNode) GetAttrByName(name string) (string, bool)
  • func (g *GreyNode) GetAttrs() eocontext.Attrs
  • func (g *GreyNode) ID() string
  • func (g *GreyNode) IP() string
  • func (g *GreyNode) Leave()
  • func (g *GreyNode) Port() int
  • func (g *GreyNode) Status() eocontext.NodeStatus
  • func (g *GreyNode) Up()
• type Matching
• type Robin
  • func NewRobin(servers ...Weighted) *Robin
  • func (l *Robin) Select(remove ...uint) Weighted
• type Rule
  • func (r *Rule) GetNodes() []eocontext.INode
• type Training
• type Weighted

Constants

const Name = "strategy-grey"

Functions

func Check

func Check(cfg *Config, workers map[eosc.RequireId]eosc.IWorker) error

func Create

func Create(id, name string, v *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)

func DoStrategy

func DoStrategy(ctx eocontext.EoContext, next eocontext.IChain) error

func Register

func Register(register eosc.IExtenderDriverRegister)

Register 注册http路由驱动工厂

Types

type ActuatorSet

type ActuatorSet interface {
	strategy.IStrategyHandler
	Set(string, *GreyHandler)
	Del(id string)
}

type Config

type Config struct {
	Name        string                `json:"name" skip:"skip"`
	Description string                `json:"description" skip:"skip"`
	Stop        bool                  `json:"stop" label:"禁用"`
	Priority    int                   `json:"priority" label:"优先级" description:"1-999"`
	Filters     strategy.FilterConfig `json:"filters" label:"过滤规则"`
	Rule        Rule                  `json:"grey" label:"灰度规则"`
}

type Controller

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

func NewController

func NewController() *Controller

func (*Controller) AllWorkers

func (c *Controller) AllWorkers() []string

func (*Controller) Check

func (c *Controller) Check(cfg interface{}) (profession, name, driver, desc string, err error)

func (*Controller) ConfigType

func (c *Controller) ConfigType() reflect.Type

func (*Controller) Del

func (c *Controller) Del(id string)

func (*Controller) Get

func (c *Controller) Get() interface{}

func (*Controller) Mode

func (c *Controller) Mode() eosc.SettingMode

func (*Controller) Set

func (c *Controller) Set(conf interface{}) (err error)

func (*Controller) Store

func (c *Controller) Store(id string)

type Grey

type Grey struct {
	drivers.WorkerBase
	// contains filtered or unexported fields
}

func (*Grey) CheckSkill

func (l *Grey) CheckSkill(skill string) bool

func (*Grey) Destroy

func (l *Grey) Destroy() error

func (*Grey) Reset

func (l *Grey) Reset(v interface{}, workers map[eosc.RequireId]eosc.IWorker) error

func (*Grey) Start

func (l *Grey) Start() error

func (*Grey) Stop

func (l *Grey) Stop() error

type GreyBalanceHandler

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

func (*GreyBalanceHandler) Select

func (g *GreyBalanceHandler) Select(ctx eocontext.EoContext) (eocontext.INode, error)

type GreyHandler

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

func NewGreyHandler

func NewGreyHandler(conf *Config) (*GreyHandler, error)

type GreyNode

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

func (*GreyNode) Addr

func (g *GreyNode) Addr() string

func (*GreyNode) Down

func (g *GreyNode) Down()

func (*GreyNode) GetAttrByName

func (g *GreyNode) GetAttrByName(name string) (string, bool)

func (*GreyNode) GetAttrs

func (g *GreyNode) GetAttrs() eocontext.Attrs

func (*GreyNode) ID

func (g *GreyNode) ID() string

func (*GreyNode) IP

func (g *GreyNode) IP() string

func (*GreyNode) Leave

func (g *GreyNode) Leave()

func (*GreyNode) Port

func (g *GreyNode) Port() int

func (*GreyNode) Status

func (g *GreyNode) Status() eocontext.NodeStatus

func (*GreyNode) Up

func (g *GreyNode) Up()

type Matching

type Matching struct {
	Type  string `json:"type"  label:"类型" enum:"header,query,cookie"`
	Name  string `json:"name"  label:"参数名"`
	Value string `json:"value"  label:"值规" `
}

type Robin

type Robin struct {
	Weighted []Weighted
	Training []*Training
}

func NewRobin

func NewRobin(servers ...Weighted) *Robin

NewRobin 初始化一个池子

func (*Robin) Select

func (l *Robin) Select(remove ...uint) Weighted

Select remove为需要屏蔽的ID，

type Rule

type Rule struct {
	KeepSession  bool        `json:"keep_session" label:"会话保持规则"`
	Nodes        []string    `json:"nodes" label:"灰度节点"`
	Distribution string      `json:"distribution" label:"流量分配方式" enum:"percent,match"` // percent   match
	Percent      int         `json:"percent" label:"灰度节点流量占比" description:"1-9999"`    // 灰度的百分比 四位数
	Matching     []*Matching `json:"matching" label:"高级匹配"`
}

func (*Rule) GetNodes

func (r *Rule) GetNodes() []eocontext.INode

type Training

type Training struct {
	Server        Weighted
	Weight        int //初始化设置权重值
	CurrentWeight int //目前的权重值
}

type Weighted

type Weighted interface {
	GetId() uint32
	GetWeight() int
}