model

type API struct {
	Name          string         `json:"name, omitempty"`
	URL           string         `json:"url"`
	Method        string         `json:"method"`
	Domain        string         `json:"domain, omitempty"`
	Status        int            `json:"status, omitempty"`
	AccessControl *AccessControl `json:"accessControl, omitempty"`
	Mock          *Mock          `json:"mock, omitempty"`
	Nodes         []*Node        `json:"nodes"`
	Desc          string         `json:"desc, omitempty"`
	Pattern       *regexp.Regexp `json:"-"`
}

type AccessControl struct {
	Whitelist []string `json:"whitelist, omitempty"`
	Blacklist []string `json:"blacklist, omitempty"`
	// contains filtered or unexported fields
}

type AddAnalysisPointReq struct {
	Addr string
	Secs int
}

type AddAnalysisPointRsp struct {
	Code int
}

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

type Bind struct {
	ClusterName string `json:"clusterName,omitempty"`
	ServerAddr  string `json:"serverAddr,omitempty"`
}

type Circuit int

type Cluster struct {
	Name   string `json:"name,omitempty"`
	LbName string `json:"lbName,omitempty"`
	// External external, e.g. create from external service discovery
	External    bool     `json:"external,omitempty"`
	BindServers []string `json:"bindServers,omitempty"`
	// contains filtered or unexported fields
}

type Clusters struct {
	Clusters map[string]*Cluster `json:"clusters"`
}

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

type Evt struct {
	Src   EvtSrc
	Type  EvtType
	Key   string
	Value interface{}
}

type EvtSrc int

type EvtType int

type GetAnalysisPointReq struct {
	Addr string
	Secs int
}

type GetAnalysisPointRsp struct {
	Code                   int `json:"schema,omitempty"`
	RequestCount           int `json:"requestCount"`
	RejectCount            int `json:"rejectCount"`
	RequestSuccessedCount  int `json:"requestSuccessedCount"`
	RequestFailureCount    int `json:"requestFailureCount"`
	ContinuousFailureCount int `json:"continuousFailureCount"`
	QPS                    int `json:"qps"`
	Max                    int `json:"max"`
	Min                    int `json:"min"`
	Avg                    int `json:"avg"`
}

type Mock struct {
	Value         string             `json:"value"`
	ContentType   string             `json:"contentType, omitempty"`
	Headers       []*MockHeader      `json:"headers, omitempty"`
	Cookies       []string           `json:"cookies, omitempty"`
	ParsedCookies []*fasthttp.Cookie `json:"-"`
}

type MockHeader struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type Node struct {
	ClusterName string        `json:"clusterName, omitempty"`
	Rewrite     string        `json:"rewrite, omitempty"`
	AttrName    string        `json:"attrName, omitempty"`
	Validations []*Validation `json:"validations, omitempty"`
}

type ProxyInfo struct {
	Conf *conf.Conf `json:"conf,omitempty"`
}

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

type Register interface {
	Registry(proxyInfo *ProxyInfo) error

	GetProxies() ([]*ProxyInfo, error)

	ChangeLogLevel(proxyAddr string, level string) error

	AddAnalysisPoint(proxyAddr, serverAddr string, secs int) error

	GetAnalysisPoint(proxyAddr, serverAddr string, secs int) (*GetAnalysisPointRsp, error)
}

type RouteResult struct {
	API   *API
	Node  *Node
	Svr   *Server
	Err   error
	Code  int
	Res   *fasthttp.Response
	Merge bool
}

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

type Routing struct {
	ClusterName string `json:"clusterName, omitempty"`
	ID          string `json:"id,omitempty"`
	Cfg         string `json:"cfg,omitempty"`
	URL         string `json:"url,omitempty"`
	// contains filtered or unexported fields
}

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

type Server struct {
	Schema string `json:"schema,omitempty"`
	Addr   string `json:"addr,omitempty"`

	// External external, e.g. create from external service discovery
	External bool `json:"external,omitempty"`
	// CheckPath begin with / checkpath, expect return CheckResponsedBody.
	CheckPath string `json:"checkPath,omitempty"`
	// CheckResponsedBody check url responsed http body, if not set, not check body
	CheckResponsedBody string `json:"checkResponsedBody"`
	// CheckDuration check interval, unit second
	CheckDuration int `json:"checkDuration,omitempty"`
	// CheckTimeout timeout to check server
	CheckTimeout int `json:"checkTimeout,omitempty"`
	// Status Server status
	Status Status `json:"status,omitempty"`

	// MaxQPS the backend server max qps support
	MaxQPS          int `json:"maxQPS,omitempty"`
	HalfToOpen      int `json:"halfToOpen,omitempty"`
	HalfTrafficRate int `json:"halfTrafficRate,omitempty"`
	CloseCount      int `json:"closeCount,omitempty"`

	BindClusters []string `json:"bindClusters,omitempty"`
	// contains filtered or unexported fields
}

type Servers struct {
	Servers map[string]*Server `json:"servers"`
}

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

type SetLogReq struct {
	Level string
}

type SetLogRsp struct {
	Code int
}

type SetReqHeadStaticMappingReq struct {
	Name  string
	Value string
}

type SetReqHeadStaticMappingRsp struct {
	Code int
}

type Status int

type Store interface {
	SaveBind(bind *Bind) error
	UnBind(bind *Bind) error
	GetBinds() ([]*Bind, error)

	SaveCluster(cluster *Cluster) error
	UpdateCluster(cluster *Cluster) error
	DeleteCluster(name string) error
	GetClusters() ([]*Cluster, error)
	GetCluster(clusterName string) (*Cluster, error)

	SaveServer(svr *Server) error
	UpdateServer(svr *Server) error
	DeleteServer(addr string) error
	GetServers() ([]*Server, error)
	GetServer(serverAddr string) (*Server, error)

	SaveAPI(api *API) error
	UpdateAPI(api *API) error
	DeleteAPI(url string, method string) error
	GetAPIs() ([]*API, error)
	GetAPI(url string, method string) (*API, error)

	SaveRouting(routing *Routing) error
	GetRoutings() ([]*Routing, error)

	Watch(evtCh chan *Evt, stopCh chan bool) error

	Clean() error
	GC() error
}

type Validation struct {
	Attr     string            `json:"attr, omitempty"`
	GetFrom  int               `json:"getFrom, omitempty"`
	Required bool              `json:"required, omitempty"`
	Rules    []*ValidationRule `json:"rules, omitempty"`
}

type ValidationRule struct {
	Type       int    `json:"type, omitempty"`
	Expression string `json:"expression, omitempty"`
	// contains filtered or unexported fields
}