@@ -193,17 +193,15 @@ get_xmpp_stanzas_count(PrevReport) ->
193
193
}} || {StanzaType , Total , Increment } <- StanzasCount ].
194
194
195
195
count_stanzas (StanzaType ) ->
196
- ExometerResults = exometer :get_values (['_' | metric_name (StanzaType )]),
197
- StanzaCount = lists :foldl (fun ({ _ , [{count , Count }, {one , _ }]}, Sum ) -> Count + Sum end ,
198
- 0 , ExometerResults ),
196
+ {ok , [{count , StanzaCount }]} = exometer :get_value (metric_name (StanzaType ), count ),
199
197
{StanzaType , StanzaCount }.
200
198
201
- metric_name (xmppMessageSent ) -> [c2s_element_in , message_count ];
202
- metric_name (xmppIqSent ) -> [c2s_element_in , iq_count ];
203
- metric_name (xmppPresenceSent ) -> [c2s_element_in , presence_count ];
204
- metric_name (xmppMessageReceived ) -> [c2s_element_out , message_count ];
205
- metric_name (xmppIqReceived ) -> [c2s_element_out , iq_count ];
206
- metric_name (xmppPresenceReceived ) -> [c2s_element_out , presence_count ].
199
+ metric_name (xmppMessageSent ) -> [global , xmpp_element_in , c2s , message_count ];
200
+ metric_name (xmppIqSent ) -> [global , xmpp_element_in , c2s , iq_count ];
201
+ metric_name (xmppPresenceSent ) -> [global , xmpp_element_in , c2s , presence_count ];
202
+ metric_name (xmppMessageReceived ) -> [global , xmpp_element_out , c2s , message_count ];
203
+ metric_name (xmppIqReceived ) -> [global , xmpp_element_out , c2s , iq_count ];
204
+ metric_name (xmppPresenceReceived ) -> [global , xmpp_element_out , c2s , presence_count ].
207
205
208
206
calculate_stanza_rate ([], NewCount ) ->
209
207
[{Type , Count , Count } || {Type , Count } <- NewCount ];
0 commit comments