Merge pull request #121 from vijeyash1/testing

testing
intelops · Jul 29, 2023 · 7b770e6 · 7b770e6
2 parents a335b83 + af9ded8
commit 7b770e6
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 11 deletions.
diff --git a/client/pkg/clients/bridge_client.go b/client/pkg/clients/bridge_client.go
@@ -29,12 +29,13 @@ type GitNats string
 const (
 	bridgeSubjects GitNats = "GITMETRICS.*"
 	bridgeSubject  GitNats = "GITMETRICS.git"
-	bridgeConsumer GitNats = "GIT_CONSUMER"
+	bridgeConsumer GitNats = "Git-Consumer"
 )
 
 // SubscribeGitBridgeNats subscribes to nats jetstream and calls
 // the respective funcs to insert data into clickhouse DB
 func (n *NATSContext) SubscribeGitBridgeNats(conn clickhouse.DBInterface) {
+	log.Printf("Creating nats consumer %s with subject: %s \n", bridgeConsumer, bridgeSubject)
 	n.stream.Subscribe(string(bridgeSubject), func(msg *nats.Msg) {
 		msg.Ack()
 		gitprovider := msg.Header.Get("GitProvider")

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
 }