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

git status

Browse Source
This commit is contained in:
sjaanus 2025-03-12 11:03:54 +02:00
parent eca36eeb5c
commit c09afa3e99
No known key found for this signature in database
GPG Key ID: 20E007C0248BA7FF
2 changed files with 25 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/lib/metrics.test.ts
View File

@ -3,6 +3,7 @@ import EventEmitter from 'events';
import type { IEventStore } from './types/stores/event-store'; import type { IEventStore } from './types/stores/event-store';
import { createTestConfig } from '../test/config/test-config'; import { createTestConfig } from '../test/config/test-config';
import { import {
CLIENT_REGISTERED,
DB_TIME, DB_TIME,
EXCEEDS_LIMIT, EXCEEDS_LIMIT,
FUNCTION_TIME, FUNCTION_TIME,
@ -287,6 +288,21 @@ test('Should collect metrics for client sdk versions', async () => {
); );
}); });
test('Should register intervals when client registered', async () => {
eventBus.emit(CLIENT_REGISTERED, {
appName: 'unleash-client-node',
environment: 'development',
interval: '15',
});
const metrics = await prometheusRegister.getSingleMetricAsString(
'client_registration_total',
);
expect(metrics).toMatch(
/client_registration_total{appName=\"unleash-client-node\",environment=\"development\",interval=\"15\"} 1/,
);
});
test('Should not collect client sdk version if sdkVersion is of wrong format or non-existent', async () => { test('Should not collect client sdk version if sdkVersion is of wrong format or non-existent', async () => {
eventStore.emit(CLIENT_REGISTER, { sdkVersion: 'unleash-client-rust' }); eventStore.emit(CLIENT_REGISTER, { sdkVersion: 'unleash-client-rust' });
eventStore.emit(CLIENT_REGISTER, {}); eventStore.emit(CLIENT_REGISTER, {});

13
src/lib/metrics.ts
View File

@ -172,7 +172,7 @@ export function registerPrometheusMetrics(
const clientRegistrationTotal = createCounter({ const clientRegistrationTotal = createCounter({
name: 'client_registration_total', name: 'client_registration_total',
help: 'Number of times a an application have registered', help: 'Number of times a an application have registered',
labelNames: ['appName', 'environment'], labelNames: ['appName', 'environment', 'interval'],
}); });
dbMetrics.registerGaugeDbMetric({ dbMetrics.registerGaugeDbMetric({
@ -812,9 +812,14 @@ export function registerPrometheusMetrics(
clientDeltaMemory.reset(); clientDeltaMemory.reset();
clientDeltaMemory.set(event.memory); clientDeltaMemory.set(event.memory);
}); });
eventBus.on(events.CLIENT_REGISTERED, ({ appName, environment }) => { eventBus.on(
clientRegistrationTotal.labels({ appName, environment }).inc(); events.CLIENT_REGISTERED,
}); ({ appName, environment, interval }) => {
clientRegistrationTotal
.labels({ appName, environment, interval })
.inc();
},
);
events.onMetricEvent( events.onMetricEvent(
eventBus, eventBus,