change cache hit metric
This commit is contained in:
@@ -132,10 +132,6 @@ const cacheHitCounter = meter.createCounter(METRIC_TYPES.cache_hit_count, {
|
|||||||
description: 'Total redis cache hits',
|
description: 'Total redis cache hits',
|
||||||
});
|
});
|
||||||
|
|
||||||
const cacheMissCounter = meter.createCounter(METRIC_TYPES.cache_miss_count, {
|
|
||||||
description: 'Total redis cache misses',
|
|
||||||
});
|
|
||||||
|
|
||||||
const accountUpdatesCounter = meter.createCounter(
|
const accountUpdatesCounter = meter.createCounter(
|
||||||
METRIC_TYPES.account_updates_count,
|
METRIC_TYPES.account_updates_count,
|
||||||
{
|
{
|
||||||
@@ -249,5 +245,4 @@ export {
|
|||||||
setLastReceivedWsMsgTs,
|
setLastReceivedWsMsgTs,
|
||||||
accountUpdatesCounter,
|
accountUpdatesCounter,
|
||||||
cacheHitCounter,
|
cacheHitCounter,
|
||||||
cacheMissCounter,
|
|
||||||
};
|
};
|
||||||
|
|||||||
17
src/index.ts
17
src/index.ts
@@ -39,7 +39,6 @@ import {
|
|||||||
accountUpdatesCounter,
|
accountUpdatesCounter,
|
||||||
cacheHitCounter,
|
cacheHitCounter,
|
||||||
setLastReceivedWsMsgTs,
|
setLastReceivedWsMsgTs,
|
||||||
cacheMissCounter,
|
|
||||||
} from './core/metrics';
|
} from './core/metrics';
|
||||||
import { handleResponseTime } from './core/middleware';
|
import { handleResponseTime } from './core/middleware';
|
||||||
import {
|
import {
|
||||||
@@ -813,7 +812,9 @@ const main = async () => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (l2Formatted) {
|
if (l2Formatted) {
|
||||||
cacheHitCounter.add(1);
|
cacheHitCounter.add(1, {
|
||||||
|
miss: false,
|
||||||
|
});
|
||||||
res.writeHead(200);
|
res.writeHead(200);
|
||||||
res.end(l2Formatted);
|
res.end(l2Formatted);
|
||||||
return;
|
return;
|
||||||
@@ -871,7 +872,9 @@ const main = async () => {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
cacheMissCounter.add(1);
|
cacheHitCounter.add(1, {
|
||||||
|
miss: true,
|
||||||
|
});
|
||||||
res.writeHead(200);
|
res.writeHead(200);
|
||||||
res.end(JSON.stringify(l2Formatted));
|
res.end(JSON.stringify(l2Formatted));
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
@@ -993,7 +996,9 @@ const main = async () => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (l2Formatted) {
|
if (l2Formatted) {
|
||||||
cacheHitCounter.add(1);
|
cacheHitCounter.add(1, {
|
||||||
|
miss: false,
|
||||||
|
});
|
||||||
return l2Formatted;
|
return l2Formatted;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -1052,7 +1057,9 @@ const main = async () => {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
cacheMissCounter.add(1);
|
cacheHitCounter.add(1, {
|
||||||
|
miss: true,
|
||||||
|
});
|
||||||
return l2Formatted;
|
return l2Formatted;
|
||||||
})
|
})
|
||||||
);
|
);
|
||||||
|
|||||||
Reference in New Issue
Block a user