added endpoint to fetch duck typed event source crds

openshift · Apr 14, 2020 · b604805 · b604805
1 parent ca30981
commit b604805
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 0 deletions.
diff --git a/cmd/bridge/main.go b/cmd/bridge/main.go
@@ -551,6 +551,24 @@ func main() {
 		},
 	}
 
+	srv.KnativeEventSourceCRDLister = &server.ResourceLister{
+		BearerToken: resourceListerToken,
+		RequestURL: &url.URL{
+			Scheme: k8sEndpoint.Scheme,
+			Host:   k8sEndpoint.Host,
+			Path:   "/apis/apiextensions.k8s.io/v1beta1/customresourcedefinitions",
+			RawQuery: url.Values{
+				"labelSelector": {"duck.knative.dev/source=true"},
+			}.Encode(),
+		},
+
+		Client: &http.Client{
+			Transport: &http.Transport{
+				TLSClientConfig: srv.K8sProxyConfig.TLSClientConfig,
+			},
+		},
+	}
+
 	listenURL := bridge.ValidateFlagIsURL("listen", *fListen)
 	switch listenURL.Scheme {
 	case "http":

diff --git a/pkg/server/server.go b/pkg/server/server.go
@@ -99,6 +99,7 @@ type Server struct {
 	MeteringProxyConfig      *proxy.Config
 	// A lister for resource listing of a particular kind
 	MonitoringDashboardConfigMapLister *ResourceLister
+	KnativeEventSourceCRDLister        *ResourceLister
 	HelmChartRepoProxyConfig           *proxy.Config
 	GOARCH                             string
 	GOOS                               string
@@ -311,6 +312,7 @@ func (s *Server) HTTPHandler() http.Handler {
 	}
 
 	handle("/api/console/monitoring-dashboard-config", authHandler(s.handleMonitoringDashboardConfigmaps))
+	handle("/api/console/crd/knative-event-sources", authHandler(s.handleKnativeEventSourceCrds))
 	handle("/api/console/version", authHandler(s.versionHandler))
 
 	// Helm Endpoints
@@ -354,6 +356,10 @@ func (s *Server) handleMonitoringDashboardConfigmaps(w http.ResponseWriter, r *h
 	s.MonitoringDashboardConfigMapLister.handleResources(w, r)
 }
 
+func (s *Server) handleKnativeEventSourceCrds(w http.ResponseWriter, r *http.Request) {
+	s.KnativeEventSourceCRDLister.handleResources(w, r)
+}
+
 func (s *Server) indexHandler(w http.ResponseWriter, r *http.Request) {
 	jsg := &jsGlobals{
 		ConsoleVersion:        version.Version,