Merge pull request #1490 from kaleido-io/metrics_fix

feat: Add metrics for messaging when performing a token transfer
hyperledger · Apr 10, 2024 · 5649da2 · 5649da2
2 parents cdd7fba + 5cb8fa8
commit 5649da2
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/internal/broadcast/message.go b/internal/broadcast/message.go
@@ -1,4 +1,4 @@
-// Copyright © 2023 Kaleido, Inc.
+// Copyright © 2024 Kaleido, Inc.
 //
 // SPDX-License-Identifier: Apache-2.0
 //
@@ -35,6 +35,9 @@ func (bm *broadcastManager) NewBroadcast(in *core.MessageInOut) syncasync.Sender
 			Message: in,
 		},
 	}
+	if bm.metrics.IsMetricsEnabled() {
+		bm.metrics.MessageSubmitted(&in.Message)
+	}
 	broadcast.setDefaults()
 	return broadcast
 }

diff --git a/internal/privatemessaging/message.go b/internal/privatemessaging/message.go
@@ -1,4 +1,4 @@
-// Copyright © 2023 Kaleido, Inc.
+// Copyright © 2024 Kaleido, Inc.
 //
 // SPDX-License-Identifier: Apache-2.0
 //
@@ -35,6 +35,9 @@ func (pm *privateMessaging) NewMessage(in *core.MessageInOut) syncasync.Sender {
 			Message: in,
 		},
 	}
+	if pm.metrics.IsMetricsEnabled() {
+		pm.metrics.MessageSubmitted(&in.Message)
+	}
 	message.setDefaults()
 	return message
 }