uncommenting all subscribtions in client

intelops · Jul 29, 2023 · c8e26a6 · c8e26a6
1 parent 484e164
commit c8e26a6
Showing 1 changed file with 10 additions and 10 deletions.
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
 }