stronk/OrchestratorTracker
1
0
Fork 0
mirror of https://github.com/stronk-dev/OrchestratorTracker.git synced 2025-07-05 02:45:10 +02:00
Code Issues Packages Projects Releases Wiki Activity

Print when removing an expired key

Browse Source
This commit is contained in:
Marco van Dijk 2023-11-03 12:41:47 +01:00
parent 67781976cc
commit aa1d1e942f
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
master/src/routes/hodler.js
View File

@ -149,7 +149,7 @@ const getEnsDomain = async function (addr) {
*/ */
const updatePrometheus = async function (tag, id, instance, orchInfo) { const updatePrometheus = async function (tag, instance, orchInfo) {
const thisInstance = orchInfo.instances[instance]; const thisInstance = orchInfo.instances[instance];
const regionInfo = orchInfo.regionalStats[tag]; const regionInfo = orchInfo.regionalStats[tag];
if (regionInfo.latestDiscoveryTime) { if (regionInfo.latestDiscoveryTime) {
@ -297,6 +297,7 @@ const onOrchUpdate = async function (id, obj, tag, region, livepeer_regions) {
!newInstance.probedFrom[key].lastTime || !newInstance.probedFrom[key].lastTime ||
now - newInstance.probedFrom[key].lastTime > CONF_KEY_EXPIRY now - newInstance.probedFrom[key].lastTime > CONF_KEY_EXPIRY
) { ) {
console.log("Removing expired key " + key + " from the probed-from cache for orch " + id);
delete newInstance.probedFrom[key]; delete newInstance.probedFrom[key];
} }
}); });
@ -306,6 +307,7 @@ const onOrchUpdate = async function (id, obj, tag, region, livepeer_regions) {
!newInstance.regions[key].lastTime || !newInstance.regions[key].lastTime ||
now - newInstance.regions[key].lastTime > CONF_KEY_EXPIRY now - newInstance.regions[key].lastTime > CONF_KEY_EXPIRY
) { ) {
console.log("Removing expired key " + key + " from the regions cache for orch " + id);
delete newInstance.regions[key]; delete newInstance.regions[key];
} }
}); });
@ -315,6 +317,7 @@ const onOrchUpdate = async function (id, obj, tag, region, livepeer_regions) {
!newInstance.livepeer_regions[key].lastTime || !newInstance.livepeer_regions[key].lastTime ||
now - newInstance.livepeer_regions[key].lastTime > CONF_KEY_EXPIRY now - newInstance.livepeer_regions[key].lastTime > CONF_KEY_EXPIRY
) { ) {
console.log("Removing expired key " + key + " from the livepeer regions cache for orch " + id);
delete newInstance.livepeer_regions[key]; delete newInstance.livepeer_regions[key];
} }
}); });
@ -353,7 +356,7 @@ const onOrchUpdate = async function (id, obj, tag, region, livepeer_regions) {
await storage.setItem("orchCache", orchCache); await storage.setItem("orchCache", orchCache);
// Update prometheus stats // Update prometheus stats
updatePrometheus(tag, id, obj.resolv.resolvedTarget, newObj); updatePrometheus(tag, obj.resolv.resolvedTarget, newObj);
console.log("Handled results for " + id + " from prober " + tag); console.log("Handled results for " + id + " from prober " + tag);
}; };