Merge pull request #123 from vijeyash1/uncommenting

uncommenting all subscribtions in client
intelops · Jul 30, 2023 · bcb4e1d · bcb4e1d
2 parents b2565ab + 5180db0
commit bcb4e1d
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 11 deletions.
diff --git a/client/pkg/application/application.go b/client/pkg/application/application.go
@@ -16,7 +16,7 @@ type Application struct {
 }
 
 func Start() *Application {
-	log.Println("Client Application started With New Code...")
+	log.Println("Client Application started...")
 	cfg := &config.Config{}
 	if err := envconfig.Process("", cfg); err != nil {
 		log.Fatalf("Could not parse env Config: %v", err)

diff --git a/client/pkg/clients/clients.go b/client/pkg/clients/clients.go
@@ -46,16 +46,16 @@ func NewNATSContext(conf *config.Config, dbClient clickhouse.DBInterface) (*NATS
 	}
 	ctx.SubscribeGitBridgeNats(dbClient)
 
-	// _, err = stream.StreamInfo("CONTAINERMETRICS")
-	// if err != nil {
-	// 	return nil, fmt.Errorf("container metrics stream not found %w", err)
-	// }
-	// ctx.SubscribeContainerNats(dbClient)
-	// _, err = stream.StreamInfo("METRICS")
-	// if err != nil {
-	// 	return nil, fmt.Errorf("kubeviz metrics stream not found %w", err)
-	// }
-	// ctx.SubscribeAllKubvizNats(dbClient)
+	_, err = stream.StreamInfo("CONTAINERMETRICS")
+	if err != nil {
+		return nil, fmt.Errorf("container metrics stream not found %w", err)
+	}
+	ctx.SubscribeContainerNats(dbClient)
+	_, err = stream.StreamInfo("METRICS")
+	if err != nil {
+		return nil, fmt.Errorf("kubeviz metrics stream not found %w", err)
+	}
+	ctx.SubscribeAllKubvizNats(dbClient)
 
 	return ctx, nil
 }