aboutsummaryrefslogtreecommitdiff
path: root/grpclb
diff options
context:
space:
mode:
authorzpencer <spencerfang@google.com>2017-11-30 15:04:40 -0800
committerGitHub <noreply@github.com>2017-11-30 15:04:40 -0800
commit9e7a4c44bef1db366adbf206fa6b81a50561bbcf (patch)
treecaa2511ea690da4458249cd6126ac38ec0c6e70d /grpclb
parentbc54970128c2caeed39d6f0fa8f7b2f117356aa8 (diff)
downloadgrpc-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.java10
-rw-r--r--grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java11
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");