Function NewRoundTripper

proxy/fastcgi/fastcgi.go:23–53

(log logging.Logger, addr, filename string)

}

func NewRoundTripper(log logging.Logger, addr, filename string) (*RoundTripper, error) {
	connFactory := gofast.SimpleConnFactory("tcp", addr)

	client, err := gofast.SimpleClientFactory(connFactory)()
	if err != nil {
		return nil, fmt.Errorf("gofast: failed creating client: %w", err)
	}

	chain := gofast.Chain(
		gofast.BasicParamsMap,
		gofast.MapHeader,
		gofast.MapEndpoint(filename),
		func(handler gofast.SessionHandler) gofast.SessionHandler {
			return func(client gofast.Client, req *gofast.Request) (*gofast.ResponsePipe, error) {
				req.Params["HTTP_HOST"] = req.Params["SERVER_NAME"]
				req.Params["SERVER_SOFTWARE"] = "Skipper"

				// Gofast sets this param to `fastcgi` which is not what the backend will expect.
				delete(req.Params, "REQUEST_SCHEME")

				return handler(client, req)
			}
		},
	)

	return &RoundTripper{
		log:     log,
		client:  client,
		handler: chain(gofast.BasicSession),
	}, nil
}

func (rt *RoundTripper) RoundTrip(req *http.Request) (*http.Response, error) {
	defer func() {