proxy

Documentation

Index

• Variables
• func GetHost(url *url.URL) string
• func GetIP(r *http.Request) string
• func IsBackendAlive(host string) bool
• type HTTPProxy
  • func NewHTTPProxy(targetHosts []string, algorithm string) (*HTTPProxy, error)
  • func (h *HTTPProxy) HealthCheck(interval uint)
  • func (h *HTTPProxy) ReadAlive(url string) bool
  • func (h *HTTPProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (h *HTTPProxy) SetAlive(url string, alive bool)

Variables

var (
	XRealIP       = http.CanonicalHeaderKey("X-Real-Ip")
	XProxy        = http.CanonicalHeaderKey("X-Proxy")
	XForwardedFor = http.CanonicalHeaderKey("X-Forwarded-For")
)

var ConnectionTimeout = 3 * time.Second

ConnectionTimeout refers to connection timeout for health check

var (
	ReverseProxy = "Balancer-Reverse-Proxy"
)

Functions

func GetHost

func GetHost(url *url.URL) string

func GetIP

func GetIP(r *http.Request) string

GetIP 获取客户端 IP

func IsBackendAlive

func IsBackendAlive(host string) bool

IsBackendAlive Attempt to establish a tcp connection to determine whether the site is alive

Types

type HTTPProxy

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

func NewHTTPProxy

func NewHTTPProxy(targetHosts []string, algorithm string) (*HTTPProxy, error)

NewHTTPProxy create new reverse proxy with url and balancer algorithm

func (*HTTPProxy) HealthCheck

func (h *HTTPProxy) HealthCheck(interval uint)

HealthCheck enable a health check goroutine for each agent

func (*HTTPProxy) ReadAlive

func (h *HTTPProxy) ReadAlive(url string) bool

ReadAlive reads the alive status of the site

func (*HTTPProxy) ServeHTTP

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

func (*HTTPProxy) SetAlive

func (h *HTTPProxy) SetAlive(url string, alive bool)

SetAlive sets the alive status to the site