Add gvk for connectcluster

Signed-off-by: sayedppqq <[email protected]>
kubedb · May 24, 2024 · 163be05 · 163be05
1 parent e9144db
commit 163be05
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/pkg/monitor/dashboard/helper.go b/pkg/monitor/dashboard/helper.go
@@ -21,6 +21,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"io"
+	kapi "kubedb.dev/apimachinery/apis/kafka/v1alpha1"
 	"log"
 	"net/http"
 	"os"
@@ -45,6 +46,12 @@ func getDB(f cmdutil.Factory, resource, ns, name string) (*unstructured.Unstruct
 		return nil, err
 	}
 
+	if resource == kapi.ResourcePluralConnectCluster {
+		kGvk := kapi.SchemeGroupVersion
+		kRes := schema.GroupVersionResource{Group: kGvk.Group, Version: kGvk.Version, Resource: resource}
+		return dc.Resource(kRes).Namespace(ns).Get(context.TODO(), name, metav1.GetOptions{})
+	}
+
 	gvk := api.SchemeGroupVersion
 	dbRes := schema.GroupVersionResource{Group: gvk.Group, Version: gvk.Version, Resource: resource}
 	return dc.Resource(dbRes).Namespace(ns).Get(context.TODO(), name, metav1.GetOptions{})