proxy

Documentation

Index

• Variables
• func GetIP(r *http.Request) string
• func GetNode(url *url.URL) string
• func IsBackendAlive(host string) bool
• type HTTPProxy
  • func NewHTTPProxy(targetNodes []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")
	XServer       = http.CanonicalHeaderKey("X-Server")
)

var ConnectionTimeout = 3 * time.Second

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

Functions

func GetIP

func GetIP(r *http.Request) string

func GetNode

func GetNode(url *url.URL) string

func IsBackendAlive

func IsBackendAlive(host string) bool

Types

type HTTPProxy

type HTTPProxy struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

HTTPProxy 是一个 HTTP 代理

func NewHTTPProxy

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

NewHTTPProxy 新建一个 HTTP 代理

func (*HTTPProxy) HealthCheck

func (h *HTTPProxy) HealthCheck(interval uint)

HealthCheck 为每个代理启用健康检查 goroutine

func (*HTTPProxy) ReadAlive

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

ReadAlive 读取站点的活动状态

func (*HTTPProxy) ServeHTTP

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

ServerHTTP 实现 http.Handler 接口

func (*HTTPProxy) SetAlive

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

SetAlive 设置站点的活动状态