diff --git a/packages/metrics/lib/prometheus/metrics/message-error/PrometheusMessageErrorCounter.spec.ts b/packages/metrics/lib/prometheus/metrics/message-error/PrometheusMessageErrorCounter.spec.ts index 52ed7db3..3fa5dc1f 100644 --- a/packages/metrics/lib/prometheus/metrics/message-error/PrometheusMessageErrorCounter.spec.ts +++ b/packages/metrics/lib/prometheus/metrics/message-error/PrometheusMessageErrorCounter.spec.ts @@ -21,7 +21,6 @@ describe('PrometheusMessageErrorCounter', () => { { name: 'test_metric', helpDescription: 'test description', - labelNames: ['errorReason'], messageVersion: (metadata: ProcessedMessageMetadata) => { registeredMessages.push(metadata) // Mocking it to check if value is registered properly return undefined @@ -85,7 +84,6 @@ describe('PrometheusMessageErrorCounter', () => { { name: 'Test metric', helpDescription: 'test description', - labelNames: ['errorReason'], }, promClient, ) @@ -120,7 +118,6 @@ describe('PrometheusMessageErrorCounter', () => { { name: 'Test metric', helpDescription: 'test description', - labelNames: ['errorReason'], }, promClient, ) @@ -168,7 +165,6 @@ describe('PrometheusMessageErrorCounter', () => { { name: 'Test metric', helpDescription: 'test description', - labelNames: ['errorReason'], messageVersion: (metadata: ProcessedMessageMetadata) => metadata.message?.metadata?.schemaVersion, }, diff --git a/packages/metrics/lib/prometheus/metrics/message-error/PrometheusMessageErrorCounter.ts b/packages/metrics/lib/prometheus/metrics/message-error/PrometheusMessageErrorCounter.ts index 4da29992..caeadb31 100644 --- a/packages/metrics/lib/prometheus/metrics/message-error/PrometheusMessageErrorCounter.ts +++ b/packages/metrics/lib/prometheus/metrics/message-error/PrometheusMessageErrorCounter.ts @@ -1,10 +1,19 @@ import type { ProcessedMessageMetadata } from '@message-queue-toolkit/core' +import type promClient from 'prom-client' import type { LabelValues } from 'prom-client' +import type { PrometheusMetricParams } from '../../types.ts' import { PrometheusMessageCounter } from './PrometheusMessageCounter.ts' export class PrometheusMessageErrorCounter< MessagePayload extends object, > extends PrometheusMessageCounter { + constructor( + metricParams: Omit, 'labelNames'>, + client: typeof promClient, + ) { + super({ ...metricParams, labelNames: ['errorReason'] }, client) + } + protected override getLabelValuesForProcessedMessage( metadata: ProcessedMessageMetadata, ): LabelValues<'errorReason'> {