Skip to content

Commit 0724bc0

Browse files
committed
Remove 'Internal' prefix from class name InternalXdsAttributes because it is causing package leakage check to fail.
1 parent d3bd6e2 commit 0724bc0

File tree

8 files changed

+22
-22
lines changed

8 files changed

+22
-22
lines changed

xds/src/main/java/io/grpc/internal/InternalAttributes.java renamed to xds/src/main/java/io/grpc/internal/XdsCommonAttributes.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
import io.grpc.Attributes;
2020
import io.grpc.EquivalentAddressGroup;
2121

22-
public final class InternalAttributes {
22+
public final class XdsCommonAttributes {
2323
/** Name associated with individual address, if available (e.g., DNS name). */
2424
@EquivalentAddressGroup.Attr
2525
public static final Attributes.Key<String> ATTR_ADDRESS_NAME =

xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@
3636
import io.grpc.Status;
3737
import io.grpc.internal.ForwardingClientStreamTracer;
3838
import io.grpc.internal.GrpcUtil;
39-
import io.grpc.internal.InternalAttributes;
39+
import io.grpc.internal.XdsCommonAttributes;
4040
import io.grpc.internal.ObjectPool;
4141
import io.grpc.services.MetricReport;
4242
import io.grpc.util.ForwardingLoadBalancerHelper;
@@ -242,9 +242,9 @@ public Subchannel createSubchannel(CreateSubchannelArgs args) {
242242
.set(ATTR_CLUSTER_LOCALITY, localityAtomicReference);
243243
if (GrpcUtil.getFlag("GRPC_EXPERIMENTAL_XDS_AUTHORITY_REWRITE", false)) {
244244
String hostname = args.getAddresses().get(0).getAttributes()
245-
.get(InternalAttributes.ATTR_ADDRESS_NAME);
245+
.get(XdsCommonAttributes.ATTR_ADDRESS_NAME);
246246
if (hostname != null) {
247-
attrsBuilder.set(InternalAttributes.ATTR_ADDRESS_NAME, hostname);
247+
attrsBuilder.set(XdsCommonAttributes.ATTR_ADDRESS_NAME, hostname);
248248
}
249249
}
250250
args = args.toBuilder().setAddresses(addresses).setAttributes(attrsBuilder.build()).build();
@@ -439,7 +439,7 @@ public PickResult pickSubchannel(PickSubchannelArgs args) {
439439
result = PickResult.withSubchannel(result.getSubchannel(),
440440
result.getStreamTracerFactory(),
441441
result.getSubchannel().getAttributes().get(
442-
InternalAttributes.ATTR_ADDRESS_NAME));
442+
XdsCommonAttributes.ATTR_ADDRESS_NAME));
443443
}
444444
}
445445
return result;

xds/src/main/java/io/grpc/xds/ClusterResolverLoadBalancer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
import io.grpc.LoadBalancerRegistry;
3030
import io.grpc.Status;
3131
import io.grpc.StatusOr;
32-
import io.grpc.internal.InternalAttributes;
32+
import io.grpc.internal.XdsCommonAttributes;
3333
import io.grpc.util.GracefulSwitchLoadBalancer;
3434
import io.grpc.util.OutlierDetectionLoadBalancer.OutlierDetectionLoadBalancerConfig;
3535
import io.grpc.xds.ClusterImplLoadBalancerProvider.ClusterImplConfig;
@@ -195,7 +195,7 @@ StatusOr<ClusterResolutionResult> edsUpdateToResult(
195195
.set(XdsAttributes.ATTR_LOCALITY_WEIGHT,
196196
localityLbInfo.localityWeight())
197197
.set(XdsAttributes.ATTR_SERVER_WEIGHT, weight)
198-
.set(InternalAttributes.ATTR_ADDRESS_NAME, endpoint.hostname())
198+
.set(XdsCommonAttributes.ATTR_ADDRESS_NAME, endpoint.hostname())
199199
.build();
200200
EquivalentAddressGroup eag;
201201
if (config.isHttp11ProxyAvailable()) {

xds/src/main/java/io/grpc/xds/internal/security/SecurityProtocolNegotiators.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
import io.grpc.Attributes;
2424
import io.grpc.Grpc;
2525
import io.grpc.internal.GrpcUtil;
26-
import io.grpc.internal.InternalAttributes;
26+
import io.grpc.internal.XdsCommonAttributes;
2727
import io.grpc.internal.ObjectPool;
2828
import io.grpc.netty.GrpcHttp2ConnectionHandler;
2929
import io.grpc.netty.InternalProtocolNegotiationEvent;
@@ -150,7 +150,7 @@ public ChannelHandler newHandler(GrpcHttp2ConnectionHandler grpcHandler) {
150150
return fallbackProtocolNegotiator.newHandler(grpcHandler);
151151
}
152152
return new ClientSecurityHandler(grpcHandler, localSslContextProviderSupplier,
153-
grpcHandler.getEagAttributes().get(InternalAttributes.ATTR_ADDRESS_NAME));
153+
grpcHandler.getEagAttributes().get(XdsCommonAttributes.ATTR_ADDRESS_NAME));
154154
}
155155

156156
@Override

xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@
5555
import io.grpc.Status.Code;
5656
import io.grpc.SynchronizationContext;
5757
import io.grpc.internal.FakeClock;
58-
import io.grpc.internal.InternalAttributes;
58+
import io.grpc.internal.XdsCommonAttributes;
5959
import io.grpc.internal.ObjectPool;
6060
import io.grpc.internal.PickFirstLoadBalancerProvider;
6161
import io.grpc.internal.PickSubchannelArgsImpl;
@@ -812,10 +812,10 @@ public void endpointAddressesAttachedWithClusterName() {
812812
new FixedResultPicker(PickResult.withSubchannel(subchannel)));
813813
}
814814
});
815-
assertThat(subchannel.getAttributes().get(InternalAttributes.ATTR_ADDRESS_NAME)).isEqualTo(
815+
assertThat(subchannel.getAttributes().get(XdsCommonAttributes.ATTR_ADDRESS_NAME)).isEqualTo(
816816
"authority-host-name");
817817
for (EquivalentAddressGroup eag : subchannel.getAllAddresses()) {
818-
assertThat(eag.getAttributes().get(InternalAttributes.ATTR_ADDRESS_NAME))
818+
assertThat(eag.getAttributes().get(XdsCommonAttributes.ATTR_ADDRESS_NAME))
819819
.isEqualTo("authority-host-name");
820820
}
821821

@@ -864,9 +864,9 @@ public void endpointAddressesAttachedWithClusterName() {
864864
}
865865
});
866866
// Sub Channel wrapper args won't have the address name although addresses will.
867-
assertThat(subchannel.getAttributes().get(InternalAttributes.ATTR_ADDRESS_NAME)).isNull();
867+
assertThat(subchannel.getAttributes().get(XdsCommonAttributes.ATTR_ADDRESS_NAME)).isNull();
868868
for (EquivalentAddressGroup eag : subchannel.getAllAddresses()) {
869-
assertThat(eag.getAttributes().get(InternalAttributes.ATTR_ADDRESS_NAME))
869+
assertThat(eag.getAttributes().get(XdsCommonAttributes.ATTR_ADDRESS_NAME))
870870
.isEqualTo("authority-host-name");
871871
}
872872

@@ -1021,7 +1021,7 @@ public String toString() {
10211021
// Unique but arbitrary string
10221022
.set(EquivalentAddressGroup.ATTR_LOCALITY_NAME, locality.toString());
10231023
if (authorityHostname != null) {
1024-
attributes.set(InternalAttributes.ATTR_ADDRESS_NAME, authorityHostname);
1024+
attributes.set(XdsCommonAttributes.ATTR_ADDRESS_NAME, authorityHostname);
10251025
}
10261026
EquivalentAddressGroup eag = new EquivalentAddressGroup(new FakeSocketAddress(name),
10271027
attributes.build());

xds/src/test/java/io/grpc/xds/ClusterResolverLoadBalancerTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@
8282
import io.grpc.inprocess.InProcessServerBuilder;
8383
import io.grpc.internal.FakeClock;
8484
import io.grpc.internal.GrpcUtil;
85-
import io.grpc.internal.InternalAttributes;
85+
import io.grpc.internal.XdsCommonAttributes;
8686
import io.grpc.testing.GrpcCleanupRule;
8787
import io.grpc.util.GracefulSwitchLoadBalancer;
8888
import io.grpc.util.GracefulSwitchLoadBalancerAccessor;
@@ -409,7 +409,7 @@ public void edsClustersEndpointHostname_addedToAddressAttribute() {
409409

410410
assertThat(
411411
childBalancer.addresses.get(0).getAttributes()
412-
.get(InternalAttributes.ATTR_ADDRESS_NAME)).isEqualTo("hostname1");
412+
.get(XdsCommonAttributes.ATTR_ADDRESS_NAME)).isEqualTo("hostname1");
413413
}
414414

415415
@Test
@@ -898,7 +898,7 @@ public void onlyLogicalDnsCluster_endpointsResolved() {
898898
newInetSocketAddress("127.0.2.1", 9000), newInetSocketAddress("127.0.2.2", 9000)))),
899899
childBalancer.addresses);
900900
assertThat(childBalancer.addresses.get(0).getAttributes()
901-
.get(InternalAttributes.ATTR_ADDRESS_NAME)).isEqualTo(DNS_HOST_NAME + ":9000");
901+
.get(XdsCommonAttributes.ATTR_ADDRESS_NAME)).isEqualTo(DNS_HOST_NAME + ":9000");
902902
}
903903

904904
@Test

xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@
5252
import io.grpc.Status;
5353
import io.grpc.StatusOr;
5454
import io.grpc.StatusRuntimeException;
55-
import io.grpc.internal.InternalAttributes;
55+
import io.grpc.internal.XdsCommonAttributes;
5656
import io.grpc.stub.StreamObserver;
5757
import io.grpc.testing.GrpcCleanupRule;
5858
import io.grpc.testing.protobuf.SimpleRequest;
@@ -842,7 +842,7 @@ private SimpleServiceGrpc.SimpleServiceBlockingStub getBlockingStub(
842842
upstreamTlsContext, tlsContextManagerForClient))
843843
: Attributes.newBuilder();
844844
if (addrNameAttribute != null) {
845-
sslContextAttributesBuilder.set(InternalAttributes.ATTR_ADDRESS_NAME, addrNameAttribute);
845+
sslContextAttributesBuilder.set(XdsCommonAttributes.ATTR_ADDRESS_NAME, addrNameAttribute);
846846
}
847847
sslContextAttributes = sslContextAttributesBuilder.build();
848848
fakeNameResolverFactory.setServers(

xds/src/test/java/io/grpc/xds/internal/security/SecurityProtocolNegotiatorsTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@
3939
import io.grpc.ChannelLogger;
4040
import io.grpc.ChannelLogger.ChannelLogLevel;
4141
import io.grpc.internal.FakeClock;
42-
import io.grpc.internal.InternalAttributes;
42+
import io.grpc.internal.XdsCommonAttributes;
4343
import io.grpc.internal.TestUtils.NoopChannelLogger;
4444
import io.grpc.netty.GrpcHttp2ConnectionHandler;
4545
import io.grpc.netty.InternalProtocolNegotiationEvent;
@@ -168,7 +168,7 @@ public void clientSecurityProtocolNegotiator_autoHostSni_hostnamePassedToClientS
168168
Attributes.newBuilder()
169169
.set(SecurityProtocolNegotiators.ATTR_SSL_CONTEXT_PROVIDER_SUPPLIER,
170170
new SslContextProviderSupplier(upstreamTlsContext, mockTlsContextManager))
171-
.set(InternalAttributes.ATTR_ADDRESS_NAME, FAKE_AUTHORITY)
171+
.set(XdsCommonAttributes.ATTR_ADDRESS_NAME, FAKE_AUTHORITY)
172172
.build());
173173
ChannelHandler newHandler = pn.newHandler(mockHandler);
174174
assertThat(newHandler).isNotNull();

0 commit comments

Comments
 (0)