Function Handler

pkg/proxy/handler.go:30–48

(breaker *Breaker, next http.Handler)

)

func Handler(breaker *Breaker, next http.Handler) http.HandlerFunc {
	return func(w http.ResponseWriter, r *http.Request) {
		if probe.IsRequestKubeletProbe(r) || breaker == nil {
			next.ServeHTTP(w, r)
			return
		}

		if err := breaker.Maybe(r.Context(), func() {
			next.ServeHTTP(w, r)
		}); err != nil {
			if errors.Is(err, context.DeadlineExceeded) || errors.Is(err, ErrRequestQueueFull) {
				http.Error(w, err.Error(), http.StatusServiceUnavailable)
			} else {
				w.WriteHeader(http.StatusInternalServerError)
				telemetry.Error(err)
			}
		}
	}
}