archive-gh-me/grpc-node
1
0
Fork 0
mirror of https://github.com/grpc/grpc-node.git synced 2026-01-18 14:18:13 +00:00
Code Issues Projects Releases Wiki Activity

Trace parsed unvalidated resources

Browse Source
This commit is contained in:
Michael Lumish 2023-09-11 15:39:19 -07:00
parent c41c3dae7b
commit 5c8b11b0be
4 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
packages/grpc-js-xds/src/xds-resource-type/cluster-resource-type.ts
View File

@ -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 {

1
packages/grpc-js-xds/src/xds-resource-type/endpoint-resource-type.ts
View File

@ -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 {

1
packages/grpc-js-xds/src/xds-resource-type/listener-resource-type.ts
View File

@ -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 {

7
packages/grpc-js-xds/src/xds-resource-type/route-config-resource-type.ts
View File

@ -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 {