grpc-js-xds: Implement updated xds dependency manager watcher API

packages/grpc-js-xds/src/resolver-xds.ts

@@ -132,18 +132,13 @@ class XdsResolver implements Resolver {
       this.xdsClient = getSingletonXdsClient();
     }
     this.xdsConfigWatcher = {
-      onUpdate: xdsConfig => {
+      onUpdate: maybeXdsConfig => {
-        this.handleXdsConfig(xdsConfig);
+        if (maybeXdsConfig.success) {
-      },
+          this.handleXdsConfig(maybeXdsConfig.value);
-      onError: (context, status) => {
+        } else {
-        trace('Resolution error for target ' + uriToString(this.target) + ' due to xDS client transient error retrieving ' + context + ': ' + status.details);
+          // This should be in the resolution_note once that is implemented
-        this.reportResolutionError(`Error retrieving resource ${context}: ${status.details}`);
+          this.reportResolutionError(`Resolution error for target ${uriToString(this.target)}: ${maybeXdsConfig.error.details}`);
-      },
+        }
-      onResourceDoesNotExist: context => {
-        trace('Resolution error for target ' + uriToString(this.target) + ': ' + context + ' does not exist');
-        /* Return an empty endpoint list and service config, to explicitly
-         * invalidate any previously returned service config */
-        this.listener.onSuccessfulResolution([], null, null, null, {});
       }
     }
   }

packages/grpc-js-xds/src/xds-dependency-manager.ts

@@ -96,9 +96,7 @@ export interface XdsConfig {
 }
 
 export interface XdsConfigWatcher {
-  onUpdate(xdsConfig: XdsConfig): void;
+  onUpdate(xdsConfig: StatusOr<XdsConfig>): void;
-  onError(context: string, status: StatusObject): void;
-  onResourceDoesNotExist(context: string): void;
 }
 
 interface AggregateClusterInfo {
@@ -401,7 +399,13 @@ export class XdsDependencyManager {
          * not already provided a ServiceConfig for the upper layer to use */
         if (!this.latestListener) {
           this.trace('Resolution error due to xDS client transient error ' + error.details);
-          this.watcher.onError(`Listener ${listenerResourceName}`, error);
+          this.watcher.onUpdate({
+            success: false,
+            error: {
+              ...error,
+              details: `Listener ${listenerResourceName}: ${error.details}`
+            }
+          });
         }
       },
       onResourceDoesNotExist: () => {
@@ -415,11 +419,24 @@ export class XdsDependencyManager {
       },
       onError: (error: StatusObject) => {
         if (!this.latestRouteConfiguration) {
-          this.watcher.onError(`RouteConfiguration ${this.latestRouteConfigName}`, error);
+          this.watcher.onUpdate({
+            success: false,
+            error: {
+              ...error,
+              details: `RouteConfiguration ${this.latestRouteConfigName}: ${error.details}`
+            }
+          });
         }
       },
       onResourceDoesNotExist: () => {
-        this.watcher.onResourceDoesNotExist(`RouteConfiguration ${this.latestRouteConfigName}`);
+        this.watcher.onUpdate({
+          success: false,
+          error: {
+            code: status.UNAVAILABLE,
+            details: `RouteConfiguration ${this.latestRouteConfigName} does not exist`,
+            metadata: new Metadata()
+          }
+        });
         this.clusterRoots = [];
         this.pruneOrphanClusters();
       }
@@ -441,8 +458,14 @@ export class XdsDependencyManager {
       this.clusterRoots = [];
       this.pruneOrphanClusters();
     }
-    this.watcher.onResourceDoesNotExist(`Listener ${this.listenerResourceName}`);
+    this.watcher.onUpdate({
-
+      success: false,
+      error: {
+        code: status.UNAVAILABLE,
+        details: `Listener ${this.listenerResourceName} does not exist`,
+        metadata: new Metadata()
+      }
+    });
   }
 
   private maybeSendUpdate() {
@@ -498,7 +521,7 @@ export class XdsDependencyManager {
         });
       }
     }
-    this.watcher.onUpdate(update);
+    this.watcher.onUpdate({success: true, value: update});
   }
 
   private addCluster(clusterName: string) {
@@ -770,10 +793,13 @@ export class XdsDependencyManager {
     if (!virtualHost) {
       this.clusterRoots = [];
       this.pruneOrphanClusters();
-      this.watcher.onError(`RouteConfiguration ${routeConfig.name}`, {
+      this.watcher.onUpdate({
-        code: status.UNAVAILABLE,
+        success: false,
-        details: `No matching route found for ${this.dataPlaneAuthority}`,
+        error: {
-        metadata: new Metadata()
+          code: status.UNAVAILABLE,
+          details: `RouteConfiguration ${routeConfig.name}: No matching route found for ${this.dataPlaneAuthority}`,
+          metadata: new Metadata()
+        }
       });
       // Report error
       return;