backend: mount cloud storage service

redpanda-data · Oct 29, 2024 · 0516a30 · 0516a30
1 parent 1bb6b58
commit 0516a30
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/backend/pkg/api/routes.go b/backend/pkg/api/routes.go
@@ -225,6 +225,9 @@ func (api *API) setupConnectWithGRPCGateway(r chi.Router) {
 	kafkaConnectSvcPath, kafkaConnectSvcHandler := dataplanev1alpha2connect.NewKafkaConnectServiceHandler(
 		hookOutput.Services[dataplanev1alpha2connect.KafkaConnectServiceName].(dataplanev1alpha2connect.KafkaConnectServiceHandler),
 		connect.WithInterceptors(hookOutput.Interceptors...))
+	cloudStorageSvcPath, cloudStorageSvcHandler := dataplanev1alpha2connect.NewCloudStorageServiceHandler(
+		hookOutput.Services[dataplanev1alpha2connect.CloudStorageServiceName].(dataplanev1alpha2connect.CloudStorageServiceHandler),
+		connect.WithInterceptors(hookOutput.Interceptors...))
 
 	ossServices := []ConnectService{
 		{
@@ -302,6 +305,11 @@ func (api *API) setupConnectWithGRPCGateway(r chi.Router) {
 			MountPath:   kafkaConnectSvcPath,
 			Handler:     kafkaConnectSvcHandler,
 		},
+		{
+			ServiceName: dataplanev1alpha2connect.CloudStorageServiceName,
+			MountPath:   cloudStorageSvcPath,
+			Handler:     cloudStorageSvcHandler,
+		},
 	}
 
 	// Order matters. OSS services first, so Enterprise handlers override OSS.