File tree Expand file tree Collapse file tree 10 files changed +31
-16
lines changed
core/src/main/java/io/grpc/internal
opentelemetry/src/main/java/io/grpc/opentelemetry
rls/src/test/java/io/grpc/rls
xds/src/test/java/io/grpc/xds Expand file tree Collapse file tree 10 files changed +31
-16
lines changed Original file line number Diff line number Diff line change @@ -55,7 +55,11 @@ dependencies {
5555tasks. named(" javadoc" ). configure {
5656 source sourceSets. context. allSource
5757 // We want io.grpc.Internal, but not io.grpc.Internal*
58+ exclude ' io/grpc/*MetricInstrument.java'
59+ exclude ' io/grpc/*MetricInstrumentRegistry.java'
5860 exclude ' io/grpc/Internal?*.java'
61+ exclude ' io/grpc/MetricRecorder.java'
62+ exclude ' io/grpc/MetricSink.java'
5963}
6064
6165tasks. named(" sourcesJar" ). configure {
Original file line number Diff line number Diff line change @@ -258,7 +258,7 @@ public T disableServiceConfigLookUp() {
258258 }
259259
260260 @ Override
261- public T addMetricSink (MetricSink metricSink ) {
261+ protected T addMetricSink (MetricSink metricSink ) {
262262 delegate ().addMetricSink (metricSink );
263263 return thisT ();
264264 }
Original file line number Diff line number Diff line change 1919/**
2020 * Internal accessors for {@link ManagedChannelBuilder}.
2121 */
22+ @ Internal
2223public final class InternalManagedChannelBuilder {
2324 private InternalManagedChannelBuilder () {}
2425
@@ -27,5 +28,10 @@ public static <T extends ManagedChannelBuilder<T>> T interceptWithTarget(
2728 return builder .interceptWithTarget (factory );
2829 }
2930
31+ public static <T extends ManagedChannelBuilder <T >> T addMetricSink (
32+ ManagedChannelBuilder <T > builder , MetricSink metricSink ) {
33+ return builder .addMetricSink (metricSink );
34+ }
35+
3036 public interface InternalInterceptorFactory extends ManagedChannelBuilder .InterceptorFactory {}
3137}
Original file line number Diff line number Diff line change @@ -1255,7 +1255,7 @@ public NameResolverRegistry getNameResolverRegistry() {
12551255 *
12561256 * @since 1.64.0
12571257 */
1258- @ ExperimentalApi ( "https://github.com/grpc/grpc-java/issues/11110" )
1258+ @ Internal
12591259 public MetricRecorder getMetricRecorder () {
12601260 return new MetricRecorder () {};
12611261 }
Original file line number Diff line number Diff line change @@ -628,8 +628,8 @@ public T disableServiceConfigLookUp() {
628628 * @return this
629629 * @since 1.64.0
630630 */
631- @ ExperimentalApi ( "https://github.com/grpc/grpc-java/issues/11110" )
632- public T addMetricSink (MetricSink metricSink ) {
631+ @ Internal
632+ protected T addMetricSink (MetricSink metricSink ) {
633633 throw new UnsupportedOperationException ();
634634 }
635635
Original file line number Diff line number Diff line change 2323/**
2424 * An internal interface representing a receiver or aggregator of gRPC metrics data.
2525 */
26- @ ExperimentalApi ( "https://github.com/grpc/grpc-java/issues/11110" )
26+ @ Internal
2727public interface MetricSink {
2828
2929 /**
Original file line number Diff line number Diff line change @@ -687,7 +687,7 @@ public ManagedChannelImplBuilder enableCheckAuthority() {
687687 }
688688
689689 @ Override
690- public ManagedChannelImplBuilder addMetricSink (MetricSink metricSink ) {
690+ protected ManagedChannelImplBuilder addMetricSink (MetricSink metricSink ) {
691691 metricSinks .add (checkNotNull (metricSink , "metric sink" ));
692692 return this ;
693693 }
Original file line number Diff line number Diff line change @@ -145,7 +145,7 @@ public void configureServerBuilder(ServerBuilder<?> serverBuilder) {
145145 * Configures the given {@link ManagedChannelBuilder} with OpenTelemetry metrics instrumentation.
146146 */
147147 public void configureChannelBuilder (ManagedChannelBuilder <?> builder ) {
148- builder .addMetricSink (sink );
148+ InternalManagedChannelBuilder .addMetricSink (builder , sink );
149149 InternalManagedChannelBuilder .interceptWithTarget (
150150 builder , openTelemetryMetricsModule ::getClientInterceptor );
151151 }
Original file line number Diff line number Diff line change 4242import io .grpc .ConnectivityStateInfo ;
4343import io .grpc .EquivalentAddressGroup ;
4444import io .grpc .ForwardingChannelBuilder2 ;
45+ import io .grpc .InternalManagedChannelBuilder ;
4546import io .grpc .LoadBalancer .CreateSubchannelArgs ;
4647import io .grpc .LoadBalancer .Helper ;
4748import io .grpc .LoadBalancer .PickDetailsConsumer ;
@@ -310,10 +311,11 @@ public void metricsWithRealChannel() throws Exception {
310311 .start ());
311312 MetricSink metrics = mock (MetricSink .class , delegatesTo (new NoopMetricSink ()));
312313 ManagedChannel channel = grpcCleanupRule .register (
313- InProcessChannelBuilder .forName ("fake-bigtable.googleapis.com" )
314- .defaultServiceConfig (parseJson (getServiceConfigJsonStr ()))
315- .addMetricSink (metrics )
316- .directExecutor ()
314+ InternalManagedChannelBuilder .addMetricSink (
315+ InProcessChannelBuilder .forName ("fake-bigtable.googleapis.com" )
316+ .defaultServiceConfig (parseJson (getServiceConfigJsonStr ()))
317+ .directExecutor (),
318+ metrics )
317319 .build ());
318320
319321 StreamRecorder <Void > recorder = StreamRecorder .create ();
Original file line number Diff line number Diff line change 4444import io .grpc .ConnectivityStateInfo ;
4545import io .grpc .DoubleHistogramMetricInstrument ;
4646import io .grpc .EquivalentAddressGroup ;
47+ import io .grpc .InternalManagedChannelBuilder ;
4748import io .grpc .LoadBalancer ;
4849import io .grpc .LoadBalancer .CreateSubchannelArgs ;
4950import io .grpc .LoadBalancer .Helper ;
@@ -1268,11 +1269,13 @@ public void metricWithRealChannel() throws Exception {
12681269 .start ());
12691270 MetricSink metrics = mock (MetricSink .class , delegatesTo (new NoopMetricSink ()));
12701271 Channel channel = grpcCleanupRule .register (
1271- InProcessChannelBuilder .forName (serverName )
1272- .defaultServiceConfig (Collections .singletonMap (
1273- "loadBalancingConfig" , Arrays .asList (Collections .singletonMap (
1274- "weighted_round_robin" , Collections .emptyMap ()))))
1275- .addMetricSink (metrics )
1272+ InternalManagedChannelBuilder .addMetricSink (
1273+ InProcessChannelBuilder .forName (serverName )
1274+ .defaultServiceConfig (Collections .singletonMap (
1275+ "loadBalancingConfig" , Arrays .asList (Collections .singletonMap (
1276+ "weighted_round_robin" , Collections .emptyMap ()))))
1277+ .directExecutor (),
1278+ metrics )
12761279 .directExecutor ()
12771280 .build ());
12781281
You can’t perform that action at this time.
0 commit comments