Skip to content

Commit 23a7e6c

Browse files
chore: generate libraries at Tue Mar 31 20:48:46 UTC 2026
1 parent 8684bb4 commit 23a7e6c

8 files changed

Lines changed: 27 additions & 28 deletions

File tree

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,8 @@ public void recordSuccess(ClientInfo clientInfo, String ipPreference) {
6161
}
6262

6363
// TODO: replace reason with an enum
64-
public void recordFailure(ClientInfo clientInfo, DirectAccessInvestigator.FailureReason reason) {
64+
public void recordFailure(
65+
ClientInfo clientInfo, DirectAccessInvestigator.FailureReason reason) {
6566
instrument.set(
6667
1,
6768
getSchema()

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ public class DirectPathCompatibleTracerImpl implements DirectPathCompatibleTrace
3030
public DirectPathCompatibleTracerImpl(
3131
ClientInfo clientInfo, MetricRegistry.RecorderRegistry recorder) {
3232
this.clientInfo = Preconditions.checkNotNull(clientInfo);
33-
this.recorder = Preconditions.checkNotNull(recorder);
33+
this.recorder = Preconditions.checkNotNull(recorder);
3434
}
3535

3636
@Override

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/dp/AlwaysEnabledDirectAccessChecker.java

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -23,21 +23,21 @@
2323

2424
@InternalApi
2525
public class AlwaysEnabledDirectAccessChecker implements DirectAccessChecker {
26-
public static final AlwaysEnabledDirectAccessChecker INSTANCE =
27-
new AlwaysEnabledDirectAccessChecker();
26+
public static final AlwaysEnabledDirectAccessChecker INSTANCE =
27+
new AlwaysEnabledDirectAccessChecker();
2828

29-
private AlwaysEnabledDirectAccessChecker() {}
29+
private AlwaysEnabledDirectAccessChecker() {}
3030

31-
@Override
32-
public boolean check(Channel channel) {
33-
if (channel instanceof ManagedChannel) {
34-
((ManagedChannel) channel).shutdownNow();
35-
}
36-
return true;
31+
@Override
32+
public boolean check(Channel channel) {
33+
if (channel instanceof ManagedChannel) {
34+
((ManagedChannel) channel).shutdownNow();
3735
}
36+
return true;
37+
}
3838

39-
@Override
40-
public void investigateFailure(@Nullable Throwable originalError) {
41-
// No-op:
42-
}
39+
@Override
40+
public void investigateFailure(@Nullable Throwable originalError) {
41+
// No-op:
42+
}
4343
}

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,6 @@
3333
import com.google.cloud.bigtable.data.v2.internal.csm.MetricsImpl;
3434
import com.google.cloud.bigtable.data.v2.internal.csm.attributes.ClientInfo;
3535
import com.google.cloud.bigtable.data.v2.internal.dp.AlwaysEnabledDirectAccessChecker;
36-
import com.google.cloud.bigtable.data.v2.internal.dp.ClassicDirectAccessChecker;
3736
import com.google.cloud.bigtable.data.v2.internal.dp.DirectAccessChecker;
3837
import com.google.cloud.bigtable.data.v2.internal.dp.NoopDirectAccessChecker;
3938
import com.google.cloud.bigtable.data.v2.stub.metrics.CustomOpenTelemetryMetricsProvider;
@@ -175,7 +174,7 @@ public static BigtableClientContext create(
175174
directAccessChecker = NoopDirectAccessChecker.INSTANCE;
176175
break;
177176
}
178-
177+
179178
BigtableTransportChannelProvider btTransportProvider =
180179
BigtableTransportChannelProvider.create(
181180
transportProvider.build(),

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

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -101,9 +101,10 @@ public class EnhancedBigtableStubSettings extends StubSettings<EnhancedBigtableS
101101
// TODO change this to true when enabling directpath by default
102102
// For now, Only runs Direct Access Checker if user explicitly sets CBT_ENABLE_DIRECTPATH=true
103103
private static final DirectPathConfig DIRECT_PATH_CONFIG =
104-
Optional.ofNullable(System.getenv("CBT_ENABLE_DIRECTPATH")).map(
105-
Boolean::parseBoolean
106-
).map(b -> b ? DirectPathConfig.FORCED_ON : DirectPathConfig.FORCED_OFF).orElse(DirectPathConfig.DEFAULT);
104+
Optional.ofNullable(System.getenv("CBT_ENABLE_DIRECTPATH"))
105+
.map(Boolean::parseBoolean)
106+
.map(b -> b ? DirectPathConfig.FORCED_ON : DirectPathConfig.FORCED_OFF)
107+
.orElse(DirectPathConfig.DEFAULT);
107108

108109
// If true, disable the bound-token-by-default feature for DirectPath.
109110
private static final boolean DIRECT_PATH_BOUND_TOKEN_DISABLED =
@@ -149,6 +150,7 @@ public enum DirectPathConfig {
149150
FORCED_ON,
150151
FORCED_OFF,
151152
}
153+
152154
private final DirectPathConfig directPathConfig;
153155

154156
private EnhancedBigtableStubSettings(Builder builder) {
@@ -634,7 +636,8 @@ private Builder() {
634636
// TODO: flip the bit setDirectAccessRequested and setTrafficDirectorEnabled once we make
635637
// client compatible by default.
636638
boolean isDirectPathRequested =
637-
directPathConfig == DirectPathConfig.FORCED_ON || directPathConfig == DirectPathConfig.DEFAULT;
639+
directPathConfig == DirectPathConfig.FORCED_ON
640+
|| directPathConfig == DirectPathConfig.DEFAULT;
638641
featureFlags =
639642
FeatureFlags.newBuilder()
640643
.setReverseScans(true)

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/ChannelPrimer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@ public interface ChannelPrimer {
2626
/**
2727
* @deprecated Use {@link #primeChannel(Channel)}
2828
*/
29-
@Deprecated
30-
default void primeChannel(ManagedChannel channel) {
29+
@Deprecated
30+
default void primeChannel(ManagedChannel channel) {
3131
primeChannel((Channel) channel);
3232
}
3333

google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/internal/csm/MetricRegistryExportTest.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,6 @@
3636
import com.google.cloud.bigtable.data.v2.internal.csm.attributes.EnvInfo;
3737
import com.google.cloud.bigtable.data.v2.internal.csm.attributes.MethodInfo;
3838
import com.google.cloud.bigtable.data.v2.internal.csm.exporter.BigtableCloudMonitoringExporter;
39-
import com.google.cloud.bigtable.data.v2.internal.dp.DirectAccessInvestigator;
4039
import com.google.cloud.bigtable.gaxx.grpc.BigtableChannelPoolSettings.LoadBalancingStrategy;
4140
import com.google.cloud.monitoring.v3.MetricServiceClient;
4241
import com.google.cloud.monitoring.v3.MetricServiceSettings;
@@ -465,9 +464,7 @@ void testDpCompatGuage() {
465464
ImmutableMap.of(
466465
"reason", "",
467466
"ip_preference", "ipv4"),
468-
ImmutableMap.of(
469-
"reason", UNKNOWN.getValue(),
470-
"ip_preference", ""));
467+
ImmutableMap.of("reason", UNKNOWN.getValue(), "ip_preference", ""));
471468
}
472469

473470
@Test

google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/internal/dp/ClassicDirectAccessCheckerTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717

1818
import static com.google.common.truth.Truth.assertThat;
1919
import static org.mockito.ArgumentMatchers.any;
20-
import static org.mockito.Mockito.anyString;
2120
import static org.mockito.Mockito.doReturn;
2221
import static org.mockito.Mockito.doThrow;
2322
import static org.mockito.Mockito.spy;

0 commit comments

Comments
 (0)