diff --git a/src/legacy/router.js b/src/legacy/router.js index 043e37b66d..6cf035350c 100644 --- a/src/legacy/router.js +++ b/src/legacy/router.js @@ -644,7 +644,6 @@ if (startDestTransformer) { ctx.status = ctxStatusCode; ctx.set('apiVersion', API_VERSION); - stats.timing('user_transform_request_latency', startTime, {}); stats.timingSummary('user_transform_request_latency_summary', startTime, {}); stats.increment('user_transform_requests', {}); stats.histogram('user_transform_output_events', transformedEvents.length, {}); diff --git a/src/services/userTransform.ts b/src/services/userTransform.ts index 83e0c807d6..2fdd43fb0d 100644 --- a/src/services/userTransform.ts +++ b/src/services/userTransform.ts @@ -170,15 +170,7 @@ export class UserTransformService { ...getTransformationMetadata(eventsToProcess[0]?.metadata), }); } finally { - stats.timing('user_transform_request_latency', userFuncStartTime, { - ...metaTags, - ...getTransformationMetadata(eventsToProcess[0]?.metadata), - }); - stats.timing('user_transform_batch_size', requestSize, { - ...metaTags, - ...getTransformationMetadata(eventsToProcess[0]?.metadata), - }); stats.timingSummary('user_transform_request_latency_summary', userFuncStartTime, { ...metaTags, diff --git a/src/util/customTransformer-v1.js b/src/util/customTransformer-v1.js index 12dab547e6..dc9306681b 100644 --- a/src/util/customTransformer-v1.js +++ b/src/util/customTransformer-v1.js @@ -98,7 +98,6 @@ async function userTransformHandlerV1( ...(events.length && events[0].metadata ? getTransformationMetadata(events[0].metadata) : {}), }; stats.counter('user_transform_function_input_events', events.length, tags); - stats.timing('user_transform_function_latency', invokeTime, tags); stats.timingSummary('user_transform_function_latency_summary', invokeTime, tags); } diff --git a/src/util/customTransformer.js b/src/util/customTransformer.js index 5ca1fae47c..3fcc8e531f 100644 --- a/src/util/customTransformer.js +++ b/src/util/customTransformer.js @@ -259,7 +259,6 @@ async function runUserTransform( }; stats.counter('user_transform_function_input_events', events.length, tags); - stats.timing('user_transform_function_latency', invokeTime, tags); stats.timingSummary('user_transform_function_latency_summary', invokeTime, tags); } diff --git a/src/util/openfaas/index.js b/src/util/openfaas/index.js index c0369deb81..ac072c4599 100644 --- a/src/util/openfaas/index.js +++ b/src/util/openfaas/index.js @@ -379,7 +379,6 @@ const executeFaasFunction = async ( }; stats.counter('user_transform_function_input_events', events.length, tags); - stats.timing('user_transform_function_latency', startTime, tags); stats.timingSummary('user_transform_function_latency_summary', startTime, tags); } }; diff --git a/src/util/prometheus.js b/src/util/prometheus.js index 860c266565..c4b92e9b3c 100644 --- a/src/util/prometheus.js +++ b/src/util/prometheus.js @@ -839,34 +839,6 @@ class Prometheus { ], }, // histogram - { - name: 'user_transform_request_latency', - help: 'user_transform_request_latency', - type: 'histogram', - labelNames: [ - 'workspaceId', - 'transformationId', - 'sourceType', - 'destinationType', - 'k8_namespace', - ], - }, - { - name: 'user_transform_batch_size', - help: 'user_transform_batch_size', - type: 'histogram', - labelNames: [ - 'workspaceId', - 'transformationId', - 'sourceType', - 'destinationType', - 'k8_namespace', - ], - buckets: [ - 1024, 102400, 524288, 1048576, 10485760, 20971520, 52428800, 104857600, 209715200, - 524288000, - ], // 1KB, 100KB, 0.5MB, 1MB, 10MB, 20MB, 50MB, 100MB, 200MB, 500MB - }, { name: 'creation_time', help: 'creation_time', @@ -917,22 +889,6 @@ class Prometheus { labelNames: [], buckets: [10, 20, 30, 40, 50, 60, 70, 80, 90, 100, 150, 200], }, - { - name: 'user_transform_function_latency', - help: 'user_transform_function_latency', - type: 'histogram', - labelNames: [ - 'identifier', - 'testMode', - 'sourceType', - 'destinationType', - 'k8_namespace', - 'errored', - 'statusCode', - 'transformationId', - 'workspaceId', - ], - }, // summary { name: 'user_transform_request_latency_summary',