fuse_strategy

type ActuatorSet interface {
	Strategy(ctx eocontext.EoContext, next eocontext.IChain, cache resources.ICache) error
	Set(string, *FuseHandler)
	Del(id string)
}

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:"fuse" label:"熔断规则"`
}

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

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

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

type FuseTimeConf struct {
	Time    int64 `json:"time" label:"熔断持续时间"`
	MaxTime int64 `json:"max_time" label:"熔断最大持续时间"`
}

type Header struct {
	Key   string `json:"key" label:"key"`
	Value string `json:"value" label:"value"`
}

type Rule struct {
	Metric           string               `json:"metric" label:"熔断维度"`         //熔断维度
	FuseCondition    StatusConditionConf  `json:"fuse_condition" label:"熔断条件"` //熔断条件
	FuseTime         FuseTimeConf         `json:"fuse_time" label:"熔断时间"`
	RecoverCondition StatusConditionConf  `json:"recover_condition" label:"恢复条件"` //恢复条件
	Response         StrategyResponseConf `json:"response" label:"响应内容"`
}

type StatusConditionConf struct {
	StatusCodes []int `json:"status_codes" label:"HTTP状态码"`
	Count       int64 `json:"count" label:"次数"`
}

type StrategyResponseConf struct {
	StatusCode  int      `json:"status_code" label:"HTTP状态码"`
	ContentType string   `json:"content_type" label:"Content-Type"`
	Charset     string   `json:"charset" label:"Charset"`
	Header      []Header `json:"header" label:"Header参数"` //key:value
	Body        string   `json:"body" label:"Body"`
}