Method ServeHTTP

pkg/proxykit/proxy.go:25–40

ServeHTTP handles incoming HTTP requests and forwards them to the backend selected by the load balancer.

(w http.ResponseWriter, r *http.Request)

// ServeHTTP handles incoming HTTP requests and forwards them to the backend
// selected by the load balancer.
func (p *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request) {
	// Select a healthy backend according to the load balancing strategy.
	backend, err := p.balancer.Next(r)
	if err != nil {
		log.Printf("[Proxy] error selecting backend: %v", err)
		http.Error(w, "service not available", http.StatusServiceUnavailable)
		return
	}

	// Increase the active connection count, and ensure it is decremented
	// when the request completes.
	backend.IncrementActiveConns()
	defer backend.DecrementActiveConns()

	backend.proxy.ServeHTTP(w, r)
}