Trace parsed unvalidated resources

grpc · Sep 11, 2023 · 5c8b11b · 5c8b11b
1 parent c41c3da
commit 5c8b11b
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 0 deletions.
diff --git a/packages/grpc-js-xds/src/xds-resource-type/cluster-resource-type.ts b/packages/grpc-js-xds/src/xds-resource-type/cluster-resource-type.ts
@@ -285,6 +285,7 @@ export class ClusterResourceType extends XdsResourceType {
       );
     }
     const message = decodeSingleResource(CDS_TYPE_URL, resource.value);
+    trace('Decoded raw resource of type ' + CDS_TYPE_URL + ': ' + JSON.stringify(message));
     const validatedMessage = this.validateResource(context, message);
     if (validatedMessage) {
       return {

diff --git a/packages/grpc-js-xds/src/xds-resource-type/endpoint-resource-type.ts b/packages/grpc-js-xds/src/xds-resource-type/endpoint-resource-type.ts
@@ -101,6 +101,7 @@ export class EndpointResourceType extends XdsResourceType {
       );
     }
     const message = decodeSingleResource(EDS_TYPE_URL, resource.value);
+    trace('Decoded raw resource of type ' + EDS_TYPE_URL + ': ' + JSON.stringify(message));
     const validatedMessage = this.validateResource(message);
     if (validatedMessage) {
       return {

diff --git a/packages/grpc-js-xds/src/xds-resource-type/listener-resource-type.ts b/packages/grpc-js-xds/src/xds-resource-type/listener-resource-type.ts
@@ -106,6 +106,7 @@ export class ListenerResourceType extends XdsResourceType {
       );
     }
     const message = decodeSingleResource(LDS_TYPE_URL, resource.value);
+    trace('Decoded raw resource of type ' + LDS_TYPE_URL + ': ' + JSON.stringify(message));
     const validatedMessage = this.validateResource(message);
     if (validatedMessage) {
       return {

diff --git a/packages/grpc-js-xds/src/xds-resource-type/route-config-resource-type.ts b/packages/grpc-js-xds/src/xds-resource-type/route-config-resource-type.ts
@@ -15,6 +15,7 @@
  *
  */
 
+import { experimental, logVerbosity } from "@grpc/grpc-js";
 import { EXPERIMENTAL_FAULT_INJECTION, EXPERIMENTAL_RETRY } from "../environment";
 import { RetryPolicy__Output } from "../generated/envoy/config/route/v3/RetryPolicy";
 import { RouteConfiguration__Output } from "../generated/envoy/config/route/v3/RouteConfiguration";
@@ -24,6 +25,11 @@ import { validateOverrideFilter } from "../http-filter";
 import { RDS_TYPE_URL, decodeSingleResource } from "../resources";
 import { Watcher, XdsClient } from "../xds-client";
 import { XdsDecodeContext, XdsDecodeResult, XdsResourceType } from "./xds-resource-type";
+const TRACER_NAME = 'xds_client';
+
+function trace(text: string): void {
+  experimental.trace(logVerbosity.DEBUG, TRACER_NAME, text);
+}
 
 const SUPPORTED_PATH_SPECIFIERS = ['prefix', 'path', 'safe_regex'];
 const SUPPPORTED_HEADER_MATCH_SPECIFIERS = [
@@ -169,6 +175,7 @@ export class RouteConfigurationResourceType extends XdsResourceType {
       );
     }
     const message = decodeSingleResource(RDS_TYPE_URL, resource.value);
+    trace('Decoded raw resource of type ' + RDS_TYPE_URL + ': ' + JSON.stringify(message));
     const validatedMessage = this.validateResource(message);
     if (validatedMessage) {
       return {