luulam/AFFiNE
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

feat: improve metrics naming (#8770)

Browse Source 
fix CLOUD-83
This commit is contained in:
darkskygit
2024-11-12 03:52:52 +00:00
parent cc9a23e424
commit 5cde590a4f
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
packages/backend/server/src/fundamentals/metrics/utils.ts
View File

@@ -26,21 +26,20 @@ export const CallMetric = (
return desc; return desc;
} }
desc.value = async function (...args: any[]) { const timer = metrics[scope].histogram('function_timer', {
const timer = metrics[scope].histogram(name, { description: 'function call time costs',
description: `function call time costs of ${name}`, unit: 'ms',
unit: 'ms', });
}); const count = metrics[scope].counter('function_calls', {
const count = metrics[scope].counter(`${name}_calls`, { description: 'function call counter',
description: `function call counter of ${name}`, });
});
const errorCount = metrics[scope].counter(`${name}_errors`, {
description: `function call error counter of ${name}`,
});
desc.value = async function (...args: any[]) {
const start = Date.now(); const start = Date.now();
let error = false;
const end = () => { const end = () => {
timer?.record(Date.now() - start, attrs); timer?.record(Date.now() - start, { ...attrs, name, error });
}; };
try { try {
@@ -50,10 +49,11 @@ export const CallMetric = (
return await originalMethod.apply(this, args); return await originalMethod.apply(this, args);
} catch (err) { } catch (err) {
if (!record || !!record.error) { if (!record || !!record.error) {
errorCount.add(1, attrs); error = true;
} }
throw err; throw err;
} finally { } finally {
count.add(1, { ...attrs, name, error });
if (!record || !!record.timer) { if (!record || !!record.timer) {
end(); end();
} }