fix: correct the prometheus metric usage

snapp-incubator · Oct 6, 2024 · a4312c3 · a4312c3
1 parent 5b4a7b0
commit a4312c3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/client/jetstream.go b/internal/client/jetstream.go
@@ -311,6 +311,7 @@ func (client *Client) corePublish(subject string) {
 				"type":    successfulPublish,
 				"cluster": clusterName,
 				"subject": subject,
+				"region":  client.config.Region,
 			}).Add(1)
 		}
 
@@ -354,6 +355,7 @@ func (client *Client) jetstreamPublish(ctx context.Context, subject string, stre
 				"type":    successfulPublish,
 				"stream":  streamName,
 				"cluster": clusterName,
+				"region":  client.config.Region,
 			}).Add(1)
 			client.logger.Info("receive ack", zap.String("stream", ack.Stream))
 		}