Skip to content

Commit b9d687d

Browse files
committed
Fix: left over name changes
1 parent d3eed7f commit b9d687d

21 files changed

Lines changed: 101 additions & 98 deletions

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -244,8 +244,8 @@ public T disableServiceConfigLookUp() {
244244

245245

246246
@Override
247-
public T childChannelConfigurator(ChannelConfigurator channelConfigurer) {
248-
delegate().childChannelConfigurator(channelConfigurer);
247+
public T childChannelConfigurator(ChannelConfigurator channelConfigurator) {
248+
delegate().childChannelConfigurator(channelConfigurator);
249249
return thisT();
250250
}
251251

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -271,8 +271,8 @@ public <X> T setNameResolverArg(NameResolver.Args.Key<X> key, X value) {
271271

272272

273273
@Override
274-
public T childChannelConfigurator(ChannelConfigurator channelConfigurer) {
275-
delegate().childChannelConfigurator(channelConfigurer);
274+
public T childChannelConfigurator(ChannelConfigurator channelConfigurator) {
275+
delegate().childChannelConfigurator(channelConfigurator);
276276
return thisT();
277277
}
278278

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -193,8 +193,8 @@ public T setBinaryLog(BinaryLog binaryLog) {
193193
}
194194

195195
@Override
196-
public T childChannelConfigurator(ChannelConfigurator channelConfigurer) {
197-
delegate().childChannelConfigurator(channelConfigurer);
196+
public T childChannelConfigurator(ChannelConfigurator channelConfigurator) {
197+
delegate().childChannelConfigurator(channelConfigurator);
198198
return thisT();
199199
}
200200

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

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,7 @@ protected T interceptWithTarget(InterceptorFactory factory) {
168168
throw new UnsupportedOperationException();
169169
}
170170

171-
public interface InterceptorFactory {
171+
protected interface InterceptorFactory {
172172
ClientInterceptor newInterceptor(String target);
173173
}
174174

@@ -660,17 +660,18 @@ public <X> T setNameResolverArg(NameResolver.Args.Key<X> key, X value) {
660660

661661

662662
/**
663-
* Sets a configurer that will be applied to all internal child channels created by this channel.
663+
* Sets a configurator that will be applied to all internal child channels created by this
664+
* channel.
664665
*
665666
* <p>This allows injecting configuration (like credentials, interceptors, or flow control)
666667
* into auxiliary channels created by gRPC infrastructure, such as xDS control plane connections.
667668
*
668-
* @param channelConfigurer the configurer to apply.
669+
* @param channelConfigurator the configurator to apply.
669670
* @return this
670671
* @since 1.81.0
671672
*/
672673
@ExperimentalApi("https://github.com/grpc/grpc-java/issues/12574")
673-
public T childChannelConfigurator(ChannelConfigurator channelConfigurer) {
674+
public T childChannelConfigurator(ChannelConfigurator channelConfigurator) {
674675
throw new UnsupportedOperationException("Not implemented");
675676
}
676677

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

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -358,7 +358,7 @@ public static final class Args {
358358
@Nullable private final MetricRecorder metricRecorder;
359359
@Nullable private final NameResolverRegistry nameResolverRegistry;
360360
@Nullable private final IdentityHashMap<Key<?>, Object> customArgs;
361-
@Nullable private final ChannelConfigurator channelConfigurer;
361+
@Nullable private final ChannelConfigurator channelConfigurator;
362362

363363
private Args(Builder builder) {
364364
this.defaultPort = checkNotNull(builder.defaultPort, "defaultPort not set");
@@ -373,7 +373,7 @@ private Args(Builder builder) {
373373
this.metricRecorder = builder.metricRecorder;
374374
this.nameResolverRegistry = builder.nameResolverRegistry;
375375
this.customArgs = cloneCustomArgs(builder.customArgs);
376-
this.channelConfigurer = builder.channelConfigurer;
376+
this.channelConfigurator = builder.channelConfigurator;
377377
}
378378

379379
/**
@@ -473,14 +473,14 @@ public ChannelLogger getChannelLogger() {
473473
}
474474

475475
/**
476-
* Returns the configurer for child channels.
476+
* Returns the configurator for child channels.
477477
*
478478
* @since 1.81.0
479479
*/
480480
@Nullable
481481
@Internal
482482
public ChannelConfigurator getChildChannelConfigurator() {
483-
return channelConfigurer;
483+
return channelConfigurator;
484484
}
485485

486486
/**
@@ -592,7 +592,7 @@ public static final class Builder {
592592
private MetricRecorder metricRecorder;
593593
private NameResolverRegistry nameResolverRegistry;
594594
private IdentityHashMap<Key<?>, Object> customArgs;
595-
private ChannelConfigurator channelConfigurer = new ChannelConfigurator() {};
595+
private ChannelConfigurator channelConfigurator = new ChannelConfigurator() {};
596596

597597
Builder() {
598598
}
@@ -713,8 +713,8 @@ public Builder setNameResolverRegistry(NameResolverRegistry registry) {
713713
*
714714
* @since 1.81.0
715715
*/
716-
public Builder setChildChannelConfigurator(ChannelConfigurator channelConfigurer) {
717-
this.channelConfigurer = channelConfigurer;
716+
public Builder setChildChannelConfigurator(ChannelConfigurator channelConfigurator) {
717+
this.channelConfigurator = channelConfigurator;
718718
return this;
719719
}
720720

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -426,18 +426,18 @@ public T setBinaryLog(BinaryLog binaryLog) {
426426

427427

428428
/**
429-
* Sets a configurer that will be applied to all internal child channels created by this server.
429+
* Sets a configurator that will be applied to all internal child channels created by this server.
430430
*
431431
* <p>This allows injecting configuration (like credentials, interceptors, or flow control)
432432
* into auxiliary channels created by gRPC infrastructure, such as xDS control plane connections
433433
* or OOB load balancing channels.
434434
*
435-
* @param channelConfigurer the configurer to apply.
435+
* @param channelConfigurator the configurator to apply.
436436
* @return this
437437
* @since 1.81.0
438438
*/
439439
@ExperimentalApi("https://github.com/grpc/grpc-java/issues/12574")
440-
public T childChannelConfigurator(ChannelConfigurator channelConfigurer) {
440+
public T childChannelConfigurator(ChannelConfigurator channelConfigurator) {
441441
throw new UnsupportedOperationException("Not implemented");
442442
}
443443

api/src/test/java/io/grpc/NameResolverTest.java

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,7 @@ public void args() {
105105
}
106106

107107
private NameResolver.Args createArgs() {
108-
ChannelConfigurator channelConfigurer = mock(ChannelConfigurator.class);
108+
ChannelConfigurator channelConfigurator = mock(ChannelConfigurator.class);
109109
return NameResolver.Args.newBuilder()
110110
.setDefaultPort(defaultPort)
111111
.setProxyDetector(proxyDetector)
@@ -117,13 +117,13 @@ private NameResolver.Args createArgs() {
117117
.setOverrideAuthority(overrideAuthority)
118118
.setMetricRecorder(metricRecorder)
119119
.setArg(FOO_ARG_KEY, customArgValue)
120-
.setChildChannelConfigurator(channelConfigurer)
120+
.setChildChannelConfigurator(channelConfigurator)
121121
.build();
122122
}
123123

124124
@Test
125125
public void args_childChannelConfigurator() {
126-
ChannelConfigurator channelConfigurer = mock(ChannelConfigurator.class);
126+
ChannelConfigurator channelConfigurator = mock(ChannelConfigurator.class);
127127

128128
SynchronizationContext realSyncContext = new SynchronizationContext(
129129
new Thread.UncaughtExceptionHandler() {
@@ -139,15 +139,16 @@ public void uncaughtException(Thread t, Throwable e) {
139139
.setSynchronizationContext(realSyncContext)
140140
.setServiceConfigParser(mock(NameResolver.ServiceConfigParser.class))
141141
.setChannelLogger(mock(ChannelLogger.class))
142-
.setChildChannelConfigurator(channelConfigurer)
142+
.setChildChannelConfigurator(channelConfigurator)
143143
.build();
144144

145-
assertThat(args.getChildChannelConfigurator()).isSameInstanceAs(channelConfigurer);
145+
ChannelConfigurator configurator = args.getChildChannelConfigurator();
146+
assertThat(configurator).isSameInstanceAs(channelConfigurator);
146147

147-
// Validate configurer accepts builders
148+
// Validate configurator accepts builders
148149
ManagedChannelBuilder<?> mockBuilder = mock(ManagedChannelBuilder.class);
149-
args.getChildChannelConfigurator().configureChannelBuilder(mockBuilder);
150-
verify(channelConfigurer).configureChannelBuilder(mockBuilder);
150+
configurator.configureChannelBuilder(mockBuilder);
151+
verify(channelConfigurator).configureChannelBuilder(mockBuilder);
151152
}
152153

153154
@Test

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,7 @@ public Result selectConfig(PickSubchannelArgs args) {
162162
* <p>This is intended for use by gRPC internal components
163163
* that are responsible for creating auxiliary {@code ManagedChannel} instances.
164164
*/
165-
private ChannelConfigurator channelConfigurer = new ChannelConfigurator() {};
165+
private ChannelConfigurator channelConfigurator = new ChannelConfigurator() {};
166166

167167
private final InternalLogId logId;
168168
private final String target;
@@ -554,8 +554,8 @@ ClientStream newSubstream(
554554
Supplier<Stopwatch> stopwatchSupplier,
555555
List<ClientInterceptor> interceptors,
556556
final TimeProvider timeProvider) {
557-
if (builder.channelConfigurer != null) {
558-
this.channelConfigurer = builder.channelConfigurer;
557+
if (builder.channelConfigurator != null) {
558+
this.channelConfigurator = builder.channelConfigurator;
559559
}
560560
this.target = checkNotNull(builder.target, "target");
561561
this.logId = InternalLogId.allocate("Channel", target);
@@ -602,7 +602,7 @@ ClientStream newSubstream(
602602
.setOverrideAuthority(this.authorityOverride)
603603
.setMetricRecorder(this.metricRecorder)
604604
.setNameResolverRegistry(builder.nameResolverRegistry)
605-
.setChildChannelConfigurator(this.channelConfigurer);
605+
.setChildChannelConfigurator(this.channelConfigurator);
606606
builder.copyAllNameResolverCustomArgsTo(nameResolverArgsBuilder);
607607
this.nameResolverArgs = nameResolverArgsBuilder.build();
608608
this.nameResolver = getNameResolver(
@@ -1501,8 +1501,8 @@ protected ManagedChannelBuilder<?> delegate() {
15011501

15021502
// Note that we follow the global configurator pattern and try to fuse the configurations as
15031503
// soon as the builder gets created
1504-
if (channelConfigurer != null) {
1505-
channelConfigurer.configureChannelBuilder(builder);
1504+
if (channelConfigurator != null) {
1505+
channelConfigurator.configureChannelBuilder(builder);
15061506
}
15071507

15081508
return builder

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -128,12 +128,12 @@ public static ManagedChannelBuilder<?> forTarget(String target) {
128128

129129
private static final Method GET_CLIENT_INTERCEPTOR_METHOD;
130130

131-
ChannelConfigurator channelConfigurer = new ChannelConfigurator() {};
131+
ChannelConfigurator channelConfigurator = new ChannelConfigurator() {};
132132

133133
@Override
134134
public ManagedChannelImplBuilder childChannelConfigurator(
135-
ChannelConfigurator channelConfigurer) {
136-
this.channelConfigurer = checkNotNull(channelConfigurer,
135+
ChannelConfigurator channelConfigurator) {
136+
this.channelConfigurator = checkNotNull(channelConfigurator,
137137
"childChannelConfigurator");
138138
return this;
139139
}
@@ -414,7 +414,7 @@ public ManagedChannelImplBuilder intercept(ClientInterceptor... interceptors) {
414414
}
415415

416416
@Override
417-
public ManagedChannelImplBuilder interceptWithTarget(InterceptorFactory factory) {
417+
protected ManagedChannelImplBuilder interceptWithTarget(InterceptorFactory factory) {
418418
// Add a placeholder instance to the interceptor list, and replace it with a real instance
419419
// during build().
420420
this.interceptors.add(new InterceptorFactoryWrapper(factory));

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

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -786,9 +786,9 @@ public void setNameResolverExtArgs() {
786786

787787
@Test
788788
public void childChannelConfigurator_setsField() {
789-
ChannelConfigurator configurer = mock(ChannelConfigurator.class);
790-
assertSame(builder, builder.childChannelConfigurator(configurer));
791-
assertSame(configurer, builder.channelConfigurer);
789+
ChannelConfigurator configurator = mock(ChannelConfigurator.class);
790+
assertSame(builder, builder.childChannelConfigurator(configurator));
791+
assertSame(configurator, builder.channelConfigurator);
792792
}
793793

794794
@Test
@@ -804,8 +804,8 @@ public void childChannelConfigurator_propagatesMetricsAndInterceptors_xdsTarget(
804804
MetricSink mockMetricSink = mock(MetricSink.class);
805805
ClientInterceptor mockInterceptor = mock(ClientInterceptor.class);
806806

807-
// Define the Configurer
808-
ChannelConfigurator configurer = new ChannelConfigurator() {
807+
// Define the Configurator
808+
ChannelConfigurator configurator = new ChannelConfigurator() {
809809
@Override
810810
public void configureChannelBuilder(ManagedChannelBuilder<?> builder) {
811811
builder.addMetricSink(mockMetricSink);
@@ -823,15 +823,15 @@ public void configureChannelBuilder(ManagedChannelBuilder<?> builder) {
823823
when(mockNameResolverFactory.newNameResolver((URI) any(),
824824
argsCaptor.capture())).thenReturn(mockNameResolver);
825825

826-
// Use the configurer and the mock factory
826+
// Use the configurator and the mock factory
827827
NameResolverRegistry registry = new NameResolverRegistry();
828828
registry.register(new NameResolverFactoryToProviderFacade(mockNameResolverFactory));
829829

830830
ManagedChannelBuilder<?> parentBuilder = new ManagedChannelImplBuilder(
831831
"xds:///my-service-target",
832832
mockClientTransportFactoryBuilder,
833833
new FixedPortProvider(DUMMY_PORT))
834-
.childChannelConfigurator(configurer)
834+
.childChannelConfigurator(configurator)
835835
.nameResolverRegistry(registry);
836836

837837
ManagedChannel channel = parentBuilder.build();
@@ -842,19 +842,19 @@ public void configureChannelBuilder(ManagedChannelBuilder<?> builder) {
842842

843843
// Extract the childChannelConfigurator from Args
844844
NameResolver.Args args = argsCaptor.getValue();
845-
ChannelConfigurator channelConfigurerInArgs = args.getChildChannelConfigurator();
846-
assertNotNull("Child channel configurer should be present in NameResolver.Args",
847-
channelConfigurerInArgs);
845+
ChannelConfigurator channelConfiguratorInArgs = args.getChildChannelConfigurator();
846+
assertNotNull("Child channel configurator should be present in NameResolver.Args",
847+
channelConfiguratorInArgs);
848848

849-
// Verify the configurer is the one we passed
850-
assertThat(channelConfigurerInArgs).isSameInstanceAs(configurer);
849+
// Verify the configurator is the one we passed
850+
assertThat(channelConfiguratorInArgs).isSameInstanceAs(configurator);
851851

852-
// Verify the configurer logically applies (by running it on a mock)
852+
// Verify the configurator logically applies (by running it on a mock)
853853
ManagedChannelBuilder<?> mockChildBuilder = mock(ManagedChannelBuilder.class);
854854
// Stub addMetricSink to return the builder to avoid generic return type issues
855855
doReturn(mockChildBuilder).when(mockChildBuilder).addMetricSink(any());
856856

857-
configurer.configureChannelBuilder(mockChildBuilder);
857+
configurator.configureChannelBuilder(mockChildBuilder);
858858
verify(mockChildBuilder).addMetricSink(mockMetricSink);
859859
}
860860

0 commit comments

Comments
 (0)