tunnel fix

Signed-off-by: sayedppqq <[email protected]>

pkg/monitor/connection/db.go

@@ -42,7 +42,7 @@ func Run(f cmdutil.Factory, args []string, prom monitor.PromSvc) {
 		log.Fatal("Enter database and specific database name as argument")
 	}
 
-	database := args[0]
+	database := monitor.ConvertedResource(args[0])
 	databaseName := args[1]
 	namespace, _, err := f.ToRawKubeConfigLoader().Namespace()
 	if err != nil {

pkg/monitor/connection/helper.go

@@ -19,8 +19,6 @@ package connection
 import (
 	"fmt"
 	"log"
-
-	"kubedb.dev/cli/pkg/monitor"
 )
 
 const (
@@ -45,7 +43,6 @@ func getIdenticalMetrics(database, databaseName string) map[string]*metrics {
 func getDBMetrics(database, name string, queries map[string]*metrics) map[string]*metrics {
 	label := "service"
 	labelValue := fmt.Sprintf("%s-stats", name)
-	database = monitor.ConvertedResource(database)
 	switch database {
 	case "mongodb":
 		queries[database] = &metrics{

pkg/monitor/prometheus_setup.go

@@ -40,7 +40,6 @@ func GetPromClientAndTunnel(config *rest.Config, prom PromSvc) (promv1.API, *por
 	if err != nil {
 		log.Fatal(err)
 	}
-	defer tunnel.Close()
 
 	promClient := getPromClient(strconv.Itoa(tunnel.Local))
 	return promClient, tunnel

pkg/monitor/util.go

@@ -17,7 +17,7 @@ limitations under the License.
 package monitor
 
 import (
-	"fmt"
+	"log"
 	"strings"
 )
 
@@ -44,7 +44,7 @@ func ConvertedResource(resource string) string {
 	case "rd", "redis", "redises":
 		res = "redis"
 	default:
-		fmt.Printf("%s is not a valid resource type \n", resource)
+		log.Fatalf("%s is not a valid resource type \n", resource)
 	}
 	return res
 }