Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

metric for time to send notifications

Browse source
This commit is contained in:
Jack Robison 2020-06-18 12:39:19 -04:00
parent 28838c1759
commit ac1a8b4daf
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lbry/wallet/server/session.py
View file

@ -169,6 +169,10 @@ class SessionManager:
"notifications_in_flight", "Count of notifications in flight", "notifications_in_flight", "Count of notifications in flight",
namespace=NAMESPACE namespace=NAMESPACE
) )
notifications_sent_metric = Histogram(
"notifications_sent", "Time to send an address notification",
namespace=NAMESPACE, buckets=HISTOGRAM_BUCKETS
)
def __init__(self, env: 'Env', db: LBRYLevelDB, bp: LBRYBlockProcessor, daemon: 'Daemon', mempool: 'MemPool', def __init__(self, env: 'Env', db: LBRYLevelDB, bp: LBRYBlockProcessor, daemon: 'Daemon', mempool: 'MemPool',
shutdown_event: asyncio.Event): shutdown_event: asyncio.Event):
@ -942,7 +946,9 @@ class LBRYElectrumX(SessionBase):
self.session_mgr.notifications_in_flight_metric.inc() self.session_mgr.notifications_in_flight_metric.inc()
status = await self.address_status(hashX) status = await self.address_status(hashX)
self.session_mgr.address_history_metric.observe(time.perf_counter() - start) self.session_mgr.address_history_metric.observe(time.perf_counter() - start)
start = time.perf_counter()
await self.send_notification(method, (alias, status)) await self.send_notification(method, (alias, status))
self.session_mgr.notifications_sent_metric.observe(time.perf_counter() - start)
finally: finally:
self.session_mgr.notifications_in_flight_metric.dec() self.session_mgr.notifications_in_flight_metric.dec()