Mirrors/unleash.unleash
1
0
Fork 0
mirror of https://github.com/Unleash/unleash.git synced 2025-09-10 17:53:36 +02:00
Code Issues Projects Releases Wiki Activity

fix: move event listeners outside metric collection

Browse Source
This commit is contained in:
Gastón Fournier 2024-10-15 11:29:33 +02:00
parent 05762e9b59
commit 9bf5ed5074
No known key found for this signature in database
GPG Key ID: AF45428626E17A8E
1 changed files with 21 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
src/lib/metrics.ts
View File

@ -460,30 +460,6 @@ export default class MetricsMonitor {
.set(stage.duration); .set(stage.duration);
}); });
eventBus.on(
events.STAGE_ENTERED,
(entered: { stage: string; feature: string }) => {
if (flagResolver.isEnabled('trackLifecycleMetrics')) {
logger.info(
`STAGE_ENTERED listened ${JSON.stringify(entered)}`,
);
}
featureLifecycleStageEnteredCounter.increment({
stage: entered.stage,
});
},
);
eventBus.on(
events.EXCEEDS_LIMIT,
({
resource,
limit,
}: { resource: string; limit: number }) => {
exceedsLimitErrorCounter.increment({ resource, limit });
},
);
featureLifecycleStageCountByProject.reset(); featureLifecycleStageCountByProject.reset();
stageCountByProjectResult.forEach((stageResult) => stageCountByProjectResult.forEach((stageResult) =>
featureLifecycleStageCountByProject featureLifecycleStageCountByProject
@ -723,6 +699,27 @@ export default class MetricsMonitor {
0, // no jitter 0, // no jitter
); );
eventBus.on(
events.EXCEEDS_LIMIT,
({ resource, limit }: { resource: string; limit: number }) => {
exceedsLimitErrorCounter.increment({ resource, limit });
},
);
eventBus.on(
events.STAGE_ENTERED,
(entered: { stage: string; feature: string }) => {
if (flagResolver.isEnabled('trackLifecycleMetrics')) {
logger.info(
`STAGE_ENTERED listened ${JSON.stringify(entered)}`,
);
}
featureLifecycleStageEnteredCounter.increment({
stage: entered.stage,
});
},
);
eventBus.on( eventBus.on(
events.REQUEST_TIME, events.REQUEST_TIME,
({ path, method, time, statusCode, appName }) => { ({ path, method, time, statusCode, appName }) => {