Revert "xds: Add logical dns cluster support to XdsDepManager"

This reverts commit d2d8ed8 as part of
reverting 297ab05.

Author: ejona86

api/src/main/java/io/grpc/NameResolver.java

@@ -303,7 +303,6 @@ public static final class Args {
     @Nullable private final Executor executor;
     @Nullable private final String overrideAuthority;
     @Nullable private final MetricRecorder metricRecorder;
-    @Nullable private final NameResolverRegistry nameResolverRegistry;
     @Nullable private final IdentityHashMap<Key<?>, Object> customArgs;
 
     private Args(Builder builder) {
@@ -317,7 +316,6 @@ private Args(Builder builder) {
       this.executor = builder.executor;
       this.overrideAuthority = builder.overrideAuthority;
       this.metricRecorder = builder.metricRecorder;
-      this.nameResolverRegistry = builder.nameResolverRegistry;
       this.customArgs = cloneCustomArgs(builder.customArgs);
     }
 
@@ -449,18 +447,6 @@ public MetricRecorder getMetricRecorder() {
       return metricRecorder;
     }
 
-    /**
-     * Returns the {@link NameResolverRegistry} that the Channel uses to look for {@link
-     * NameResolver}s.
-     *
-     * @since 1.74.0
-     */
-    public NameResolverRegistry getNameResolverRegistry() {
-      if (nameResolverRegistry == null) {
-        throw new IllegalStateException("NameResolverRegistry is not set in Builder");
-      }
-      return nameResolverRegistry;
-    }
 
     @Override
     public String toString() {
@@ -475,7 +461,6 @@ public String toString() {
           .add("executor", executor)
           .add("overrideAuthority", overrideAuthority)
           .add("metricRecorder", metricRecorder)
-          .add("nameResolverRegistry", nameResolverRegistry)
           .toString();
     }
 
@@ -495,7 +480,6 @@ public Builder toBuilder() {
       builder.setOffloadExecutor(executor);
       builder.setOverrideAuthority(overrideAuthority);
       builder.setMetricRecorder(metricRecorder);
-      builder.setNameResolverRegistry(nameResolverRegistry);
       builder.customArgs = cloneCustomArgs(customArgs);
       return builder;
     }
@@ -524,7 +508,6 @@ public static final class Builder {
       private Executor executor;
       private String overrideAuthority;
       private MetricRecorder metricRecorder;
-      private NameResolverRegistry nameResolverRegistry;
       private IdentityHashMap<Key<?>, Object> customArgs;
 
       Builder() {
@@ -631,16 +614,6 @@ public Builder setMetricRecorder(MetricRecorder metricRecorder) {
         return this;
       }
 
-      /**
-       * See {@link Args#getNameResolverRegistry}.  This is an optional field.
-       *
-       * @since 1.74.0
-       */
-      public Builder setNameResolverRegistry(NameResolverRegistry registry) {
-        this.nameResolverRegistry = registry;
-        return this;
-      }
-
       /**
        * Builds an {@link Args}.
        *

core/src/main/java/io/grpc/internal/ManagedChannelImpl.java

@@ -597,8 +597,7 @@ ClientStream newSubstream(
             .setChannelLogger(channelLogger)
             .setOffloadExecutor(this.offloadExecutorHolder)
             .setOverrideAuthority(this.authorityOverride)
-            .setMetricRecorder(this.metricRecorder)
-            .setNameResolverRegistry(builder.nameResolverRegistry);
+            .setMetricRecorder(this.metricRecorder);
     builder.copyAllNameResolverCustomArgsTo(nameResolverArgsBuilder);
     this.nameResolverArgs = nameResolverArgsBuilder.build();
     this.nameResolver = getNameResolver(
@@ -686,7 +685,11 @@ static NameResolver getNameResolver(
     // We wrap the name resolver in a RetryingNameResolver to give it the ability to retry failures.
     // TODO: After a transition period, all NameResolver implementations that need retry should use
     //       RetryingNameResolver directly and this step can be removed.
-    NameResolver usedNameResolver = RetryingNameResolver.wrap(resolver, nameResolverArgs);
+    NameResolver usedNameResolver = new RetryingNameResolver(resolver,
+          new BackoffPolicyRetryScheduler(new ExponentialBackoffPolicy.Provider(),
+              nameResolverArgs.getScheduledExecutorService(),
+              nameResolverArgs.getSynchronizationContext()),
+          nameResolverArgs.getSynchronizationContext());
 
     if (overrideAuthority == null) {
       return usedNameResolver;

core/src/main/java/io/grpc/internal/RetryingNameResolver.java

@@ -27,22 +27,13 @@
  *
  * <p>The {@link NameResolver} used with this
  */
-public final class RetryingNameResolver extends ForwardingNameResolver {
-  public static NameResolver wrap(NameResolver retriedNameResolver, Args args) {
-    // For migration, this might become conditional
-    return new RetryingNameResolver(
-        retriedNameResolver,
-        new BackoffPolicyRetryScheduler(
-            new ExponentialBackoffPolicy.Provider(),
-            args.getScheduledExecutorService(),
-            args.getSynchronizationContext()),
-        args.getSynchronizationContext());
-  }
+final class RetryingNameResolver extends ForwardingNameResolver {
 
   private final NameResolver retriedNameResolver;
   private final RetryScheduler retryScheduler;
   private final SynchronizationContext syncContext;
 
+
   /**
    * Creates a new {@link RetryingNameResolver}.
    *

core/src/test/java/io/grpc/internal/DnsNameResolverTest.java

@@ -207,7 +207,14 @@ private RetryingNameResolver newResolver(
 
     // In practice the DNS name resolver provider always wraps the resolver in a
     // RetryingNameResolver which adds retry capabilities to it. We use the same setup here.
-    return (RetryingNameResolver) RetryingNameResolver.wrap(dnsResolver, args);
+    return new RetryingNameResolver(
+        dnsResolver,
+        new BackoffPolicyRetryScheduler(
+            new ExponentialBackoffPolicy.Provider(),
+            fakeExecutor.getScheduledExecutorService(),
+            syncContext
+        ),
+        syncContext);
   }
 
   @Before