👌 add endpoint type

DataDog · Aug 31, 2022 · eafac47 · eafac47
1 parent 50c4c1f
commit eafac47
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 4 deletions.
diff --git a/packages/core/src/domain/configuration/endpointBuilder.ts b/packages/core/src/domain/configuration/endpointBuilder.ts
@@ -19,7 +19,7 @@ const INTAKE_TRACKS = {
   sessionReplay: 'replay',
 }
 
-type EndpointType = keyof typeof ENDPOINTS
+export type EndpointType = keyof typeof ENDPOINTS
 
 export type EndpointBuilder = ReturnType<typeof createEndpointBuilder>
 

diff --git a/packages/core/src/domain/configuration/index.ts b/packages/core/src/domain/configuration/index.ts
@@ -5,7 +5,7 @@ export {
   DefaultPrivacyLevel,
   validateAndBuildConfiguration,
 } from './configuration'
-export { createEndpointBuilder, EndpointBuilder } from './endpointBuilder'
+export { createEndpointBuilder, EndpointBuilder, EndpointType } from './endpointBuilder'
 export {
   isExperimentalFeatureEnabled,
   updateExperimentalFeatures,

diff --git a/packages/core/src/transport/httpRequest.ts b/packages/core/src/transport/httpRequest.ts
@@ -1,4 +1,4 @@
-import type { EndpointBuilder } from '../domain/configuration'
+import type { EndpointBuilder, EndpointType } from '../domain/configuration'
 import { addTelemetryError } from '../domain/telemetry'
 import { monitor } from '../tools/monitor'
 import { isExperimentalFeatureEnabled } from '../domain/configuration'
@@ -21,6 +21,7 @@ export interface HttpResponse {
 export interface Payload {
   data: string | FormData
   bytesCount: number
+  type?: EndpointType
 }
 
 export function createHttpRequest(endpointBuilder: EndpointBuilder, bytesLimit: number) {
@@ -30,6 +31,7 @@ export function createHttpRequest(endpointBuilder: EndpointBuilder, bytesLimit:
 
   return {
     send: (payload: Payload) => {
+      payload.type = endpointBuilder.endpointType
       if (!isExperimentalFeatureEnabled('retry')) {
         fetchKeepAliveStrategy(endpointBuilder, bytesLimit, payload)
       } else {

diff --git a/packages/core/src/transport/sendWithRetryStrategy.ts b/packages/core/src/transport/sendWithRetryStrategy.ts
@@ -99,7 +99,10 @@ function send(
 function retryQueuedPayloads(state: RetryState, sendStrategy: SendStrategy, reason: string) {
   const previousQueue = state.queuedPayloads
   if (previousQueue.isFull()) {
-    addTelemetryDebug(`retry queue full after ${reason}`)
+    addTelemetryDebug('retry queue full', {
+      reason,
+      endpointType: previousQueue.first().type,
+    })
   }
   state.queuedPayloads = newPayloadQueue()
   while (previousQueue.size() > 0) {