framework

type CircuitConfig struct {
	Type       string   `toml:"type"`
	Service    string   `toml:"service"`
	Resource   string   `toml:"resource"`
	End        string   `toml:"end"`
	Open       bool     `toml:"open"`
	Threshold  float64  `toml:"threshold"`
	Strategy   string   `toml:"strategy"`
	MinSamples int64    `toml:"minsamples"`
	RT         duration `toml:"rt"`
}

type ClientOption func(*ClientOptions)

type ClientOptions struct{}

type DefaultCircuit struct {
	Server Resource `toml:"server"`
	Client Resource `toml:"client"`
}

type Framework struct {
	// Name is discovery name, it is from deploy platform by default.
	// Name will be used to register to discovery service
	Name      string
	Namespace string
	JobName   string
	App       string
	// 版本
	Version      string
	Deps         string
	LogDir       string
	LogLevel     string
	LogRotate    string
	ConfigPath   string
	ConfigMemory []byte
	Clusters     *upstream.ClusterManager
	Manager      *registry.ServiceManager
	// contains filtered or unexported fields
}

type JSONDataLogOption struct {
	Path     string `toml:"path"`
	Rotate   string `toml:"rotate"`
	TaskName string `toml:"task_name"`
}

type Mode int

type Option func(framework *Framework)

type Resource struct {
	ratelimit.LimiterConfig
	breaker.BreakerConfig
}

type ServerClient struct {
	// 应用名称
	APPName *string `toml:"app_name"`
	// 服务发现名称
	ServiceName string `toml:"service_name"`
	Ipport      string `toml:"endpoints"`
	Balancetype string `toml:"balancetype"`
	// 请求协议,比如http
	ProtoType           string `toml:"proto"`
	ConnectTimeout      int    `toml:"connect_timeout"`
	Namespace           string `toml:"namespace"`
	ReadTimeout         int    `toml:"read_timeout"`
	WriteTimeout        int    `toml:"write_timeout"`
	KeepaliveTimeout    int    `toml:"keepalive_timeout"`
	MaxIdleConns        int    `toml:"max_idleconn"`
	MaxIdleConnsPerHost int    `toml:"max_idleconn_perhost"`
	RetryTimes          int    `toml:"retry_times"`
	SlowTime            int    `toml:"slow_time"`
	EndpointsFrom       string `toml:"endpoints_from"`
	ConsulName          string `toml:"consul_name"`
	LoadBalanceStat     bool   `toml:"loadbalance_stat"`
	DC                  string `toml:"dc,omitempty"`

	// checker config
	CheckInterval      upstreamconfig.Duration `toml:"check_interval"`
	UnHealthyThreshold uint32                  `toml:"check_unhealth_threshold"`
	HealthyThreshold   uint32                  `toml:"check_healthy_threshold"`

	// lb advance config
	LBPanicThreshold int        `toml:"lb_panic_threshold"`
	LBSubsetKeys     [][]string `toml:"lb_subset_selectors"`
	LBDefaultKeys    []string   `toml:"lb_default_keys"`

	// detector config
	DetectInterval             upstreamconfig.Duration `toml:"detect_interval"`
	BaseEjectionDuration       upstreamconfig.Duration `toml:"base_ejection_duration"`
	ConsecutiveError           uint64                  `toml:"consecutive_error"`
	ConsecutiveConnectionError uint64                  `toml:"consecutive_connect_error"`
	MaxEjectionPercent         uint64                  `toml:"max_ejection_percent"`
	SuccessRateMinHosts        uint64                  `toml:"success_rate_min_hosts"`
	SuccessRateRequestVolume   uint64                  `toml:"success_rate_request_volume"`
	SuccessRateStdevFactor     float64                 `toml:"success_rate_stdev_factor"`
	Cluster                    upstreamconfig.Cluster

	Resource map[string]Resource `toml:"resource"` // 当用于http服务调用时, key=uri; 当用于rpc服务调用时, key=func_name; * 通配置
}