proxy

Documentation

Index

• type Endpoint
  • 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) 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)
}

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 更新后端点