Function NewProxyServer

proxy.go:53–79

(options *ProxyServerOptions)

}

func NewProxyServer(options *ProxyServerOptions) *ProxyServer {
	proxy := httputil.NewSingleHostReverseProxy(options.Target)

	server := &ProxyServer{
		options,
		proxy,
	}

	originalDirector := proxy.Director
	proxy.Director = func(req *http.Request) {
		originalDirector(req)
		server.modifyRequest(req)
	}

	proxy.ModifyResponse = server.modifyResponse
	proxy.ErrorHandler = func(rw http.ResponseWriter, r *http.Request, err error) {
		if errors.Is(err, context.Canceled) {
			return
		}
		msg := fmt.Sprintf("%+v\n", err)
		log.Println(msg)
		rw.WriteHeader(http.StatusInternalServerError)
		_, _ = rw.Write([]byte(msg))
	}

	return server
}

func (p *ProxyServer) Handler() func(http.ResponseWriter, *http.Request) {
	return func(w http.ResponseWriter, r *http.Request) {