backend

Documentation

Index

• type Backend
• type BackendPool
  • func (p *BackendPool) GetNextPeer(alive *IsAlive) (*Backend, int64)
  • func (p *BackendPool) NextIndex() int
• type IsAlive
  • func (i *IsAlive) GetStatus(url string) (int64, bool)
  • func (i *IsAlive) HealthCheck()
  • func (i *IsAlive) SetStatus(url string, status int64)

Types

type Backend

type Backend struct {
	Url          *url.URL
	Host         string
	ReverseProxy *httputil.ReverseProxy
}

type BackendPool

type BackendPool struct {
	Backends []*Backend // 所有节点
	Current  uint64     // 当前轮到的节点索引
	Port     string     // 本地端口
	BackUp   *Backend   // 备用
	TlsCert  string     // cert.pem 路径
	TlsKey   string     // key.pem 路径
}

func (*BackendPool) GetNextPeer

func (p *BackendPool) GetNextPeer(alive *IsAlive) (*Backend, int64)

func (*BackendPool) NextIndex

func (p *BackendPool) NextIndex() int

type IsAlive

type IsAlive struct {
	M       sync.Map // map[host]rtt
	TimeOut int64
}

func (*IsAlive) GetStatus

func (i *IsAlive) GetStatus(url string) (int64, bool)

func (*IsAlive) HealthCheck

func (i *IsAlive) HealthCheck()

func (*IsAlive) SetStatus

func (i *IsAlive) SetStatus(url string, status int64)