fix

Author: sushanb

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/csm/Metrics.java

@@ -18,6 +18,7 @@
 import com.google.api.gax.tracing.ApiTracerFactory;
 import com.google.cloud.bigtable.data.v2.internal.csm.attributes.ClientInfo;
 import com.google.cloud.bigtable.data.v2.internal.csm.tracers.ChannelPoolMetricsTracer;
+import com.google.cloud.bigtable.data.v2.internal.csm.tracers.DirectPathCompatibleTracer;
 import io.grpc.ManagedChannelBuilder;
 import java.io.Closeable;
 import java.io.IOException;
@@ -31,6 +32,9 @@ public interface Metrics extends Closeable {
   @Nullable
   ChannelPoolMetricsTracer getChannelPoolMetricsTracer();
 
+  @Nullable
+  DirectPathCompatibleTracer getDirectPathCompatibleTracer();
+
   void start();
 
   @Override

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/csm/MetricsImpl.java

@@ -31,6 +31,8 @@
 import com.google.cloud.bigtable.data.v2.internal.csm.tracers.BuiltinMetricsTracerFactory;
 import com.google.cloud.bigtable.data.v2.internal.csm.tracers.ChannelPoolMetricsTracer;
 import com.google.cloud.bigtable.data.v2.internal.csm.tracers.CompositeTracerFactory;
+import com.google.cloud.bigtable.data.v2.internal.csm.tracers.DefaultDirectPathCompatibleTracer;
+import com.google.cloud.bigtable.data.v2.internal.csm.tracers.DirectPathCompatibleTracer;
 import com.google.cloud.bigtable.data.v2.internal.csm.tracers.Pacemaker;
 import com.google.common.base.Preconditions;
 import com.google.common.collect.ImmutableList;
@@ -67,6 +69,7 @@ public class MetricsImpl implements Metrics, Closeable {
 
   @Nullable private final GrpcOpenTelemetry grpcOtel;
   @Nullable private final ChannelPoolMetricsTracer channelPoolMetricsTracer;
+  @Nullable private final DirectPathCompatibleTracer directPathCompatibleTracer;
   @Nullable private final Pacemaker pacemaker;
   private final List<ScheduledFuture<?>> tasks = new ArrayList<>();
 
@@ -94,6 +97,7 @@ public MetricsImpl(
       this.internalRecorder = metricRegistry.newRecorderRegistry(internalOtel.getMeterProvider());
       this.pacemaker = new Pacemaker(internalRecorder, clientInfo, "background");
       this.channelPoolMetricsTracer = new ChannelPoolMetricsTracer(internalRecorder, clientInfo);
+      this.directPathCompatibleTracer = new DefaultDirectPathCompatibleTracer(clientInfo, internalRecorder);
       this.grpcOtel =
           GrpcOpenTelemetry.newBuilder()
               .sdk(internalOtel)
@@ -109,6 +113,7 @@ public MetricsImpl(
       this.grpcOtel = null;
       this.pacemaker = null;
       this.channelPoolMetricsTracer = null;
+      this.directPathCompatibleTracer = null;
     }
 
     if (userOtel != null) {
@@ -171,6 +176,12 @@ public ChannelPoolMetricsTracer getChannelPoolMetricsTracer() {
     return channelPoolMetricsTracer;
   }
 
+  @Nullable
+  @Override
+  public DirectPathCompatibleTracer getDirectPathCompatibleTracer() {
+    return directPathCompatibleTracer;
+  }
+
   public static OpenTelemetrySdk createBuiltinOtel(
       MetricRegistry metricRegistry,
       ClientInfo clientInfo,

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/csm/tracers/DefaultDirectPathCompatibleTracer.java

@@ -0,0 +1,42 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.google.cloud.bigtable.data.v2.internal.csm.tracers;
+
+import com.google.api.core.InternalApi;
+import com.google.cloud.bigtable.data.v2.internal.csm.MetricRegistry;
+import com.google.cloud.bigtable.data.v2.internal.csm.attributes.ClientInfo;
+
+@InternalApi
+public class DefaultDirectPathCompatibleTracer implements DirectPathCompatibleTracer {
+    private final ClientInfo clientInfo;
+    private final MetricRegistry.RecorderRegistry recorder;
+
+    public DefaultDirectPathCompatibleTracer(
+            ClientInfo clientInfo, MetricRegistry.RecorderRegistry recorder) {
+        this.clientInfo = clientInfo;
+        this.recorder = recorder;
+    }
+
+    @Override
+    public void recordSuccess(String ipPreference) {
+        recorder.dpCompatGuage.recordSuccess(clientInfo, ipPreference);
+    }
+
+    @Override
+    public void recordFailure(String reason) {
+        recorder.dpCompatGuage.recordFailure(clientInfo, reason);
+    }
+}

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/csm/tracers/DirectPathCompatibleTracer.java

@@ -0,0 +1,39 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.google.cloud.bigtable.data.v2.internal.csm.tracers;
+
+import com.google.api.core.InternalApi;
+
+/**
+ * Interface for recording DirectPath/DirectAccess eligibility metrics.
+ */
+@InternalApi
+public interface DirectPathCompatibleTracer {
+
+    /**
+     * Records that the environment is eligible and successfully connected via DirectPath.
+     *
+     * @param ipPreference The IP preference used (e.g., "ipv6").
+     */
+    void recordSuccess(String ipPreference);
+
+    /**
+     * Records that the environment is not eligible or failed to connect via DirectPath.
+     *
+     * @param reason The reason for the failure (e.g., "routing_check_failed").
+     */
+    void recordFailure(String reason);
+}

…table/gaxx/grpc/DirectAccessChecker.java …data/v2/stub/BigtableChannelFactory.javagoogle-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/DirectAccessChecker.java renamed to google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableChannelFactory.java google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/DirectAccessChecker.java renamed to google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableChannelFactory.java

@@ -13,14 +13,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.google.cloud.bigtable.gaxx.grpc;
+package com.google.cloud.bigtable.data.v2.stub;
 
 import com.google.api.core.InternalApi;
-import io.grpc.Channel;
+import io.grpc.ManagedChannel;
+
+import java.io.IOException;
 
 @InternalApi
-/* Evaluates whether a given channel supports Direct Access. */
-public interface DirectAccessChecker {
-    /// Performs a request on the provided channel to check for Direct Access eligibility.
-    boolean check(Channel channel );
+public interface BigtableChannelFactory {
+    ManagedChannel createSingleChannel() throws IOException;
 }

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableClientContext.java

@@ -166,7 +166,8 @@ public static BigtableClientContext create(
               transportProvider.build(),
               channelPrimer,
               metrics.getChannelPoolMetricsTracer(),
-              backgroundExecutor);
+              backgroundExecutor,               metrics.getDirectPathCompatibleTracer()
+                  );
 
       builder.setTransportChannelProvider(btTransportProvider);
     }

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/DirectAccessChecker.java

@@ -0,0 +1,34 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.google.cloud.bigtable.data.v2.stub;
+
+import com.google.api.core.InternalApi;
+import com.google.cloud.bigtable.data.v2.internal.csm.tracers.DirectPathCompatibleTracer;
+import io.grpc.Channel;
+
+import javax.annotation.Nullable;
+
+@InternalApi
+/* Evaluates whether a given channel supports Direct Access. */
+public interface DirectAccessChecker {
+    /**
+     * Evaluates if Direct Access is available by creating a test channel.
+     *
+     * @param channelFactory A factory to create the test channel
+     * @return true if the channel is eligible for Direct Access
+     */
+    boolean check(BigtableChannelFactory channelFactory, @Nullable DirectPathCompatibleTracer tracer);
+}

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/EnhancedBigtableStubSettings.java

@@ -634,12 +634,16 @@ private Builder() {
 
       perOpSettings = new ClientOperationSettings.Builder();
 
+      // Note: RouteLookup evaluates and returns directpath targets
+      // only if Traffic Director sends the request (with grpc as target type)
+      // For GFE/CFE, sending setDirectAccessRequested
+      // is fine as GFE/CFE sends with gslb target type
       featureFlags =
           FeatureFlags.newBuilder()
               .setReverseScans(true)
               .setLastScannedRowResponses(true)
-              .setDirectAccessRequested(DIRECT_PATH_ENABLED)
-              .setTrafficDirectorEnabled(DIRECT_PATH_ENABLED)
+              .setDirectAccessRequested(true)
+              .setTrafficDirectorEnabled(true)
               .setPeerInfo(true);
     }
 

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/MetadataExtractorInterceptor.java

@@ -29,10 +29,16 @@
 import io.grpc.ClientInterceptors;
 import io.grpc.ForwardingClientCall;
 import io.grpc.ForwardingClientCallListener;
+import io.grpc.Grpc;
 import io.grpc.Metadata;
 import io.grpc.MethodDescriptor;
 import io.grpc.Status;
 import io.grpc.alts.AltsContextUtil;
+
+import java.net.Inet4Address;
+import java.net.Inet6Address;
+import java.net.InetSocketAddress;
+import java.net.SocketAddress;
 import java.time.Duration;
 import java.util.Base64;
 import java.util.regex.Matcher;
@@ -85,6 +91,12 @@ public SidebandData getSidebandData() {
   }
 
   public static class SidebandData {
+    public enum IpProtocol {
+      IPV4,
+      IPV6,
+      UNKNOWN
+    }
+
     private static final CallOptions.Key<SidebandData> KEY =
         CallOptions.Key.create("bigtable-sideband");
 
@@ -105,6 +117,7 @@ public static SidebandData from(CallOptions callOptions) {
     @Nullable private volatile ResponseParams responseParams;
     @Nullable private volatile PeerInfo peerInfo;
     @Nullable private volatile Duration gfeTiming;
+    @Nullable private volatile IpProtocol ipProtocol;
 
     @Nullable
     public ResponseParams getResponseParams() {
@@ -121,16 +134,23 @@ public Duration getGfeTiming() {
       return gfeTiming;
     }
 
+    @Nullable
+    public IpProtocol getIpProtocol() {
+      return ipProtocol;
+    }
+
     private void reset() {
       responseParams = null;
       peerInfo = null;
       gfeTiming = null;
+      ipProtocol = IpProtocol.UNKNOWN;
     }
 
     void onResponseHeaders(Metadata md, Attributes attributes) {
       responseParams = extractResponseParams(md);
       gfeTiming = extractGfeLatency(md);
       peerInfo = extractPeerInfo(md, gfeTiming, attributes);
+      ipProtocol = extractIpProtocol(attributes);
     }
 
     void onClose(Status status, Metadata trailers) {
@@ -139,6 +159,20 @@ void onClose(Status status, Metadata trailers) {
       }
     }
 
+    @Nullable
+    private static IpProtocol extractIpProtocol(Attributes attributes) {
+      SocketAddress remoteAddr = attributes.get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR);
+      if (remoteAddr instanceof InetSocketAddress) {
+        InetSocketAddress inetAddr = (InetSocketAddress) remoteAddr;
+        if (inetAddr.getAddress() instanceof Inet4Address) {
+          return IpProtocol.IPV4;
+        } else if (inetAddr.getAddress() instanceof Inet6Address) {
+          return IpProtocol.IPV6;
+        }
+      }
+      return IpProtocol.UNKNOWN;
+    }
+
     @Nullable
     private static Duration extractGfeLatency(Metadata metadata) {
       String serverTiming = metadata.get(SERVER_TIMING_HEADER_KEY);