diff options
author | zpencer <spencerfang@google.com> | 2017-11-30 15:04:40 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-11-30 15:04:40 -0800 |
commit | 9e7a4c44bef1db366adbf206fa6b81a50561bbcf (patch) | |
tree | caa2511ea690da4458249cd6126ac38ec0c6e70d /grpclb | |
parent | bc54970128c2caeed39d6f0fa8f7b2f117356aa8 (diff) | |
download | grpc-grpc-java-9e7a4c44bef1db366adbf206fa6b81a50561bbcf.tar.gz |
core: move WithLog and LogId to io.grpc (#3813)
The channelz service must not live in io.grpc.internal, and channelz
needs to be able to get the identifier of the entities it
tracks. Since io.grpc can not refer to io.grpc.internal, the LogId
must be moved out of internal.
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 | 11 |
2 files changed, 12 insertions, 9 deletions
diff --git a/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java b/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java index 3b6b1eeee..ec7326eec 100644 --- a/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java +++ b/grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java @@ -22,12 +22,12 @@ 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.LogId; import io.grpc.internal.ObjectPool; -import io.grpc.internal.WithLogId; import java.util.ArrayList; import java.util.Collections; import java.util.List; @@ -42,10 +42,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 WithLogId { +class GrpclbLoadBalancer extends LoadBalancer implements InternalWithLogId { private static final Logger logger = Logger.getLogger(GrpclbLoadBalancer.class.getName()); - private final LogId logId = LogId.allocate(getClass().getName()); + private final InternalLogId logId = InternalLogId.allocate(getClass().getName()); private final Helper helper; private final Factory pickFirstBalancerFactory; @@ -81,7 +81,7 @@ class GrpclbLoadBalancer extends LoadBalancer implements WithLogId { } @Override - public LogId getLogId() { + public InternalLogId 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 a82d29c17..56e451a06 100644 --- a/grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java +++ b/grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java @@ -33,6 +33,7 @@ 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; @@ -42,7 +43,6 @@ 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; @@ -53,8 +53,8 @@ import java.util.Arrays; import java.util.Collections; import java.util.HashMap; import java.util.List; -import java.util.Map.Entry; import java.util.Map; +import java.util.Map.Entry; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; @@ -92,7 +92,7 @@ final class GrpclbState { } }; - private final LogId logId; + private final InternalLogId logId; private final String serviceName; private final Helper helper; private final TimeProvider time; @@ -127,7 +127,10 @@ final class GrpclbState { new RoundRobinPicker(Collections.<DropEntry>emptyList(), Arrays.asList(BUFFER_ENTRY)); GrpclbState( - Helper helper, TimeProvider time, ScheduledExecutorService timerService, LogId logId) { + Helper helper, + TimeProvider time, + ScheduledExecutorService timerService, + InternalLogId logId) { this.helper = checkNotNull(helper, "helper"); this.time = checkNotNull(time, "time provider"); this.timerService = checkNotNull(timerService, "timerService"); |