diff options
author | zpencer <spencerfang@google.com> | 2018-01-25 17:19:00 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-01-25 17:19:00 -0800 |
commit | b109595ad37f11bc2546be4c0f0635975c345c56 (patch) | |
tree | edccbccae92154338f974b240e922f0b189e1049 /grpclb | |
parent | 2a93e6b92fe8fe0583d6fc947f63c749babddc33 (diff) | |
download | grpc-grpc-java-b109595ad37f11bc2546be4c0f0635975c345c56.tar.gz |
core: move Instrumented, LogId, WithLogId to io.grpc.internal as public (#3995)
Diffstat (limited to 'grpclb')
-rw-r--r-- | grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java | 10 | ||||
-rw-r--r-- | grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java | 6 |
2 files changed, 8 insertions, 8 deletions
diff --git a/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java b/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java index adc280bb5..17e3a5030 100644 --- a/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java +++ b/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java @@ -22,13 +22,13 @@ import com.google.common.annotations.VisibleForTesting; import io.grpc.Attributes; import io.grpc.ConnectivityStateInfo; import io.grpc.EquivalentAddressGroup; -import io.grpc.InternalLogId; -import io.grpc.InternalWithLogId; import io.grpc.LoadBalancer; import io.grpc.Status; import io.grpc.grpclb.GrpclbConstants.LbPolicy; import io.grpc.internal.GrpcAttributes; +import io.grpc.internal.LogId; import io.grpc.internal.ObjectPool; +import io.grpc.internal.WithLogId; import java.util.ArrayList; import java.util.Collections; import java.util.List; @@ -43,10 +43,10 @@ import javax.annotation.Nullable; * <p>Optionally, when requested by the naming system, will delegate the work to a local pick-first * or round-robin balancer. */ -class GrpclbLoadBalancer extends LoadBalancer implements InternalWithLogId { +class GrpclbLoadBalancer extends LoadBalancer implements WithLogId { private static final Logger logger = Logger.getLogger(GrpclbLoadBalancer.class.getName()); - private final InternalLogId logId = InternalLogId.allocate(getClass().getName()); + private final LogId logId = LogId.allocate(getClass().getName()); private final Helper helper; private final Factory pickFirstBalancerFactory; @@ -82,7 +82,7 @@ class GrpclbLoadBalancer extends LoadBalancer implements InternalWithLogId { } @Override - public InternalLogId getLogId() { + public LogId getLogId() { return logId; } diff --git a/grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java b/grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java index 34c96abf9..b35988f7f 100644 --- a/grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java +++ b/grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java @@ -33,7 +33,6 @@ import io.grpc.Attributes; import io.grpc.ConnectivityState; import io.grpc.ConnectivityStateInfo; import io.grpc.EquivalentAddressGroup; -import io.grpc.InternalLogId; import io.grpc.LoadBalancer.Helper; import io.grpc.LoadBalancer.PickResult; import io.grpc.LoadBalancer.PickSubchannelArgs; @@ -43,6 +42,7 @@ import io.grpc.ManagedChannel; import io.grpc.Metadata; import io.grpc.Status; import io.grpc.grpclb.LoadBalanceResponse.LoadBalanceResponseTypeCase; +import io.grpc.internal.LogId; import io.grpc.stub.StreamObserver; import java.net.InetAddress; import java.net.InetSocketAddress; @@ -92,7 +92,7 @@ final class GrpclbState { } }; - private final InternalLogId logId; + private final LogId logId; private final String serviceName; private final Helper helper; private final TimeProvider time; @@ -130,7 +130,7 @@ final class GrpclbState { Helper helper, TimeProvider time, ScheduledExecutorService timerService, - InternalLogId logId) { + LogId logId) { this.helper = checkNotNull(helper, "helper"); this.time = checkNotNull(time, "time provider"); this.timerService = checkNotNull(timerService, "timerService"); |