From 41eab22117dc60b5dbfc9fc60858707daa0e9c4c Mon Sep 17 00:00:00 2001
From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com>
Date: Fri, 13 Nov 2020 20:44:59 +0000
Subject: [PATCH] Send pubsub metrics to metrics server (#13584) (#13585)

(cherry picked from commit 34bf80ba9c2b35f7d4be8829bc73c1b37da485b2)

Co-authored-by: Tyera Eulberg <teulberg@gmail.com>
---
 core/src/rpc_subscriptions.rs | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/core/src/rpc_subscriptions.rs b/core/src/rpc_subscriptions.rs
index 717849e463..cedc507e88 100644
--- a/core/src/rpc_subscriptions.rs
+++ b/core/src/rpc_subscriptions.rs
@@ -941,6 +941,19 @@ impl RpcSubscriptions {
                 num_signatures_notified,
                 signatures_time,
             );
+            datapoint_info!(
+                "rpc_subscriptions",
+                ("source", source.to_string(), String),
+                ("num_account_subscriptions", pubkeys.len(), i64),
+                ("num_account_pubkeys_notified", num_pubkeys_notified, i64),
+                ("accounts_time", accounts_time.as_us() as i64, i64),
+                ("num_program_subscriptions", programs.len(), i64),
+                ("num_programs_notified", num_programs_notified, i64),
+                ("programs_time", programs_time.as_us() as i64, i64),
+                ("num_signature_subscriptions", signatures.len(), i64),
+                ("num_signatures_notified", num_signatures_notified, i64),
+                ("signatures_time", signatures_time.as_us() as i64, i64)
+            );
         }
     }