aboutsummaryrefslogtreecommitdiff
path: root/grpclb
diff options
context:
space:
mode:
authorzpencer <spencerfang@google.com>2018-01-25 17:19:00 -0800
committerGitHub <noreply@github.com>2018-01-25 17:19:00 -0800
commitb109595ad37f11bc2546be4c0f0635975c345c56 (patch)
treeedccbccae92154338f974b240e922f0b189e1049 /grpclb
parent2a93e6b92fe8fe0583d6fc947f63c749babddc33 (diff)
downloadgrpc-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.java10
-rw-r--r--grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java6
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");