mempool_process_time_metric
This commit is contained in:
parent
8e01f415d0
commit
dfda41f85f
1 changed files with 4 additions and 0 deletions
|
@ -1,3 +1,5 @@
|
||||||
|
import time
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
from scribe.blockchain.daemon import LBCDaemon
|
from scribe.blockchain.daemon import LBCDaemon
|
||||||
from scribe.hub.session import SessionManager
|
from scribe.hub.session import SessionManager
|
||||||
|
@ -45,7 +47,9 @@ class HubServerService(BlockchainReaderService):
|
||||||
|
|
||||||
def _detect_changes(self):
|
def _detect_changes(self):
|
||||||
super()._detect_changes()
|
super()._detect_changes()
|
||||||
|
start = time.perf_counter()
|
||||||
self.mempool_notifications.update(self.mempool.refresh())
|
self.mempool_notifications.update(self.mempool.refresh())
|
||||||
|
self.mempool.mempool_process_time_metric.observe(time.perf_counter() - start)
|
||||||
|
|
||||||
async def poll_for_changes(self):
|
async def poll_for_changes(self):
|
||||||
await super().poll_for_changes()
|
await super().poll_for_changes()
|
||||||
|
|
Loading…
Reference in a new issue