proxy

Documentation

Index

• type Endpoint
  • func (e Endpoint) GetAddr() string
  • func (e Endpoint) GetHTTPAddr() string
  • func (e Endpoint) GetName() string
  • func (e Endpoint) String() string
• type EndpointList
  • func CreateEndpoints(endpoints []string) EndpointList
  • func (e *EndpointList) Add(endpoints ...string)
  • func (e *EndpointList) Delete(endpoints ...string)
  • func (e *EndpointList) HaveEndpoint(endpoint string) bool
  • func (e *EndpointList) Len() int
  • func (e *EndpointList) Selec(i int) Endpoint
• type HTTPProxy
  • func (h *HTTPProxy) Do(r *http.Request) (*http.Response, error)
  • func (h *HTTPProxy) Proxy(w http.ResponseWriter, r *http.Request)
  • func (h *HTTPProxy) UpdateEndpoints(endpoints ...string)
• type LoadBalance
  • func NewRoundRobin() LoadBalance
• type Proxy
  • func CreateProxy(name string, mode string, endpoints []string) Proxy
• type RoundRobin
  • func (rr RoundRobin) Select(r *http.Request, endpoints EndpointList) Endpoint
• type SelectBalance
  • func NewSelectBalance() *SelectBalance
  • func (s *SelectBalance) Select(r *http.Request, endpoints EndpointList) Endpoint
• type WebSocketProxy
  • func (h *WebSocketProxy) Do(r *http.Request) (*http.Response, error)
  • func (h *WebSocketProxy) Proxy(w http.ResponseWriter, req *http.Request)
  • func (h *WebSocketProxy) UpdateEndpoints(endpoints ...string)

Types

type Endpoint

type Endpoint string

Endpoint Endpoint

func (Endpoint) GetAddr

func (e Endpoint) GetAddr() string

GetAddr get addr

func (Endpoint) GetHTTPAddr

func (e Endpoint) GetHTTPAddr() string

GetHTTPAddr get http url

func (Endpoint) GetName

func (e Endpoint) GetName() string

GetName get endpoint name

func (Endpoint) String

func (e Endpoint) String() string

type EndpointList

type EndpointList []Endpoint

EndpointList EndpointList

func CreateEndpoints

func CreateEndpoints(endpoints []string) EndpointList

CreateEndpoints CreateEndpoints

func (*EndpointList) Add

func (e *EndpointList) Add(endpoints ...string)

Add Add

func (*EndpointList) Delete

func (e *EndpointList) Delete(endpoints ...string)

Delete Delete

func (*EndpointList) HaveEndpoint

func (e *EndpointList) HaveEndpoint(endpoint string) bool

HaveEndpoint Whether or not there is a endpoint

func (*EndpointList) Len

func (e *EndpointList) Len() int

Len Len

func (*EndpointList) Selec

func (e *EndpointList) Selec(i int) Endpoint

Selec Selec

type HTTPProxy

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

HTTPProxy HTTPProxy

func (*HTTPProxy) Do

func (h *HTTPProxy) Do(r *http.Request) (*http.Response, error)

Do do proxy

func (*HTTPProxy) Proxy

func (h *HTTPProxy) Proxy(w http.ResponseWriter, r *http.Request)

Proxy 代理

func (*HTTPProxy) UpdateEndpoints

func (h *HTTPProxy) UpdateEndpoints(endpoints ...string)

UpdateEndpoints 更新端点

type LoadBalance

type LoadBalance interface {
	Select(r *http.Request, endpoints EndpointList) Endpoint
}

LoadBalance LoadBalance

func NewRoundRobin

func NewRoundRobin() LoadBalance

NewRoundRobin create a RoundRobin

type Proxy

type Proxy interface {
	Proxy(w http.ResponseWriter, r *http.Request)
	Do(r *http.Request) (*http.Response, error)
	UpdateEndpoints(endpoints ...string) // format: ["name=>ip:port", ...]
}

Proxy proxy

func CreateProxy

func CreateProxy(name string, mode string, endpoints []string) Proxy

CreateProxy 创建代理

type RoundRobin

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

RoundRobin round robin loadBalance impl

func (RoundRobin) Select

func (rr RoundRobin) Select(r *http.Request, endpoints EndpointList) Endpoint

Select select a server from servers using RoundRobin

type SelectBalance

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

SelectBalance 选择性负载均衡

func NewSelectBalance

func NewSelectBalance() *SelectBalance

NewSelectBalance 创建选择性负载均衡

func (*SelectBalance) Select

func (s *SelectBalance) Select(r *http.Request, endpoints EndpointList) Endpoint

Select 负载

type WebSocketProxy

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

WebSocketProxy WebSocketProxy

func (*WebSocketProxy) Do

func (h *WebSocketProxy) Do(r *http.Request) (*http.Response, error)

Do do proxy

func (*WebSocketProxy) Proxy

func (h *WebSocketProxy) Proxy(w http.ResponseWriter, req *http.Request)

func (*WebSocketProxy) UpdateEndpoints

func (h *WebSocketProxy) UpdateEndpoints(endpoints ...string)

UpdateEndpoints 更新后端点