Method ServeHTTP

pkg/server/proxy/handler.go:32–60

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

}

func (h *HttpHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
	// we already parsed and looked up the cluster in the clusterresolver middleware,
	// and potentially have stored the shard URL in the context already
	shardURL := lookup.ShardURLFrom(r.Context())
	if shardURL != nil {
		r.URL = shardURL
	}

	mux := http.NewServeMux()

	// fallback for all unrecognized URLs
	if h.DefaultHandler != nil {
		mux.Handle("/", h.DefaultHandler)
	}

	for _, mapping := range h.Mappings {
		p := strings.TrimRight(mapping.Path, "/")

		if p == "/clusters" {
			mux.Handle("/clusters/{cluster}", mapping.Handler)
			mux.Handle("/clusters/{cluster}/{trail...}", mapping.Handler)
		} else {
			mux.Handle(p, mapping.Handler)
			mux.Handle(p+"/{trail...}", mapping.Handler)
		}
	}

	mux.ServeHTTP(w, r)
}