feat(2981): middleware stats.

interledger · Nov 20, 2024 · 9195b7c · 9195b7c
1 parent f80bdec
commit 9195b7c
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 7 deletions.
diff --git a/packages/backend/src/payment-method/ilp/connector/core/middleware/balance.ts b/packages/backend/src/payment-method/ilp/connector/core/middleware/balance.ts
@@ -21,8 +21,8 @@ export function createBalanceMiddleware(): ILPMiddleware {
     }: ILPContext,
     next: () => Promise<void>
   ): Promise<void> => {
-    const stopTimer = services.telemetry.startTimer('balanceMiddleware', {
-      callName: 'balanceMiddleware'
+    const stopTimer = services.telemetry.startTimer('balance_middleware_next', {
+      callName: 'balanceMiddleware:next'
     })
     const { amount } = request.prepare
     const logger = services.logger.child(

diff --git a/packages/backend/src/payment-method/ilp/connector/core/middleware/error-handler.ts b/packages/backend/src/payment-method/ilp/connector/core/middleware/error-handler.ts
@@ -12,9 +12,9 @@ export function createIncomingErrorHandlerMiddleware(
 ): ILPMiddleware {
   return async (ctx: ILPContext, next: () => Promise<void>): Promise<void> => {
     const stopTimer = ctx.services.telemetry.startTimer(
-      'createIncomingErrorHandlerMiddleware',
+      'create_incoming_error_handler_middleware_next',
       {
-        callName: 'createIncomingErrorHandlerMiddleware'
+        callName: 'createIncomingErrorHandlerMiddleware:next'
       }
     )
     try {

diff --git a/packages/backend/src/payment-method/ilp/connector/core/middleware/stream-address.ts b/packages/backend/src/payment-method/ilp/connector/core/middleware/stream-address.ts
@@ -5,9 +5,12 @@ export function createStreamAddressMiddleware(): ILPMiddleware {
     { request, services: { streamServer, telemetry }, state }: ILPContext,
     next: () => Promise<void>
   ): Promise<void> => {
-    const stopTimer = telemetry.startTimer('createStreamAddressMiddleware', {
-      callName: 'createStreamAddressMiddleware'
-    })
+    const stopTimer = telemetry.startTimer(
+      'create_stream_address_middleware_decode_tag',
+      {
+        callName: 'createStreamAddressMiddleware:decodePaymentTag'
+      }
+    )
     const { destination } = request.prepare
     // To preserve sender privacy, the accountId wasn't included in the original destination address.
     state.streamDestination = streamServer.decodePaymentTag(destination)