Function dockerSocketHandler

socket-proxy/pkg/handler.go:24–41

(socket string)

var DockerSocketHandler = dockerSocketHandler

func dockerSocketHandler(socket string) http.HandlerFunc {
	rp := &reverseproxy.ReverseProxy{
		Director: func(req *http.Request) {
			req.URL.Scheme = "http"
			req.URL.Host = "api.moby.localhost"
			req.RequestURI = req.URL.String()
		},
		Transport: &http.Transport{
			DialContext:        dialDockerSocket(socket),
			DisableCompression: true,
		},
	}

	return func(w http.ResponseWriter, r *http.Request) {
		w.Header().Set("Transfer-Encoding", "chunked")
		rp.ServeHTTP(w, r)
	}
}

func endpointNotAllowed(w http.ResponseWriter, _ *http.Request) {
	http.Error(w, "Endpoint not allowed", http.StatusForbidden)