| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| GrpclbLoadBalancerFactory.java | 20 import io.grpc.LoadBalancer;
27 * A factory for {@link LoadBalancer}s that uses the GRPCLB protocol.
33 public class GrpclbLoadBalancerFactory extends LoadBalancer.Factory {
45 public LoadBalancer newLoadBalancer(LoadBalancer.Helper helper) {
|
| SubchannelPool.java | 21 import io.grpc.LoadBalancer.Helper;
22 import io.grpc.LoadBalancer.Subchannel;
|
| CachedSubchannelPool.java | 25 import io.grpc.LoadBalancer.Helper;
26 import io.grpc.LoadBalancer.Subchannel;
|
| GrpclbLoadBalancer.java | 27 import io.grpc.LoadBalancer;
40 * A {@link LoadBalancer} that uses the GRPCLB protocol.
45 class GrpclbLoadBalancer extends LoadBalancer implements InternalWithLogId {
|
| GrpclbState.java | 37 import io.grpc.LoadBalancer.Helper;
38 import io.grpc.LoadBalancer.PickResult;
39 import io.grpc.LoadBalancer.PickSubchannelArgs;
40 import io.grpc.LoadBalancer.Subchannel;
41 import io.grpc.LoadBalancer.SubchannelPicker;
503 .augmentDescription("Stream to GRPCLB LoadBalancer had an error"));
513 Status.UNAVAILABLE.withDescription("Stream to GRPCLB LoadBalancer was closed"));
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| AbstractSubchannel.java | 22 import io.grpc.LoadBalancer;
27 * io.grpc.LoadBalancer.Helper#createSubchannel}.
29 abstract class AbstractSubchannel extends LoadBalancer.Subchannel {
|
| AutoConfiguredLoadBalancerFactory.java | 24 import io.grpc.LoadBalancer;
25 import io.grpc.LoadBalancer.Helper;
26 import io.grpc.LoadBalancer.PickResult;
27 import io.grpc.LoadBalancer.PickSubchannelArgs;
28 import io.grpc.LoadBalancer.SubchannelPicker;
37 final class AutoConfiguredLoadBalancerFactory extends LoadBalancer.Factory {
49 public LoadBalancer newLoadBalancer(Helper helper) {
53 private static final class NoopLoadBalancer extends LoadBalancer {
70 static final class AutoConfiguredLoadBalancer extends LoadBalancer {
72 private LoadBalancer delegate
[all...] |
| PickSubchannelArgsImpl.java | 23 import io.grpc.LoadBalancer.PickSubchannelArgs;
|
| OobChannel.java | 39 import io.grpc.LoadBalancer;
40 import io.grpc.LoadBalancer.PickResult;
41 import io.grpc.LoadBalancer.PickSubchannelArgs;
42 import io.grpc.LoadBalancer.Subchannel;
43 import io.grpc.LoadBalancer.SubchannelPicker;
62 * A ManagedChannel backed by a single {@link InternalSubchannel} and used for {@link LoadBalancer}
|
| DelayedClientTransport.java | 26 import io.grpc.LoadBalancer.PickResult;
27 import io.grpc.LoadBalancer.PickSubchannelArgs;
28 import io.grpc.LoadBalancer.SubchannelPicker;
328 // (which would shutdown the transports and LoadBalancer) because the gap should be shorter
|
| AbstractManagedChannelImplBuilder.java | 31 import io.grpc.LoadBalancer;
118 @Nullable LoadBalancer.Factory loadBalancerFactory;
239 public final T loadBalancerFactory(LoadBalancer.Factory loadBalancerFactory) {
241 "directServerAddress is set (%s), which forbids the use of LoadBalancer.Factory",
|
| ManagedChannelImpl.java | 53 import io.grpc.LoadBalancer;
54 import io.grpc.LoadBalancer.PickResult;
55 import io.grpc.LoadBalancer.PickSubchannelArgs;
56 import io.grpc.LoadBalancer.SubchannelPicker;
120 private final LoadBalancer.Factory loadBalancerFactory;
199 // 2b loadBalancer.shutdown()
200 // * LoadBalancer will shutdown subchannels and OOB channels
201 // 2c loadBalancer <- null
261 // Until LoadBalancer is shutdown, it may still create new subchannels. We catch them
366 // when the caller of exitIdleMode() is about to use the returned loadBalancer
[all...] |
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| PickFirstBalancerFactory.java | 25 import io.grpc.LoadBalancer.PickResult;
26 import io.grpc.LoadBalancer.PickSubchannelArgs;
27 import io.grpc.LoadBalancer.Subchannel;
28 import io.grpc.LoadBalancer.SubchannelPicker;
32 * A {@link LoadBalancer} that provides no load balancing mechanism over the
37 public final class PickFirstBalancerFactory extends LoadBalancer.Factory {
52 public LoadBalancer newLoadBalancer(LoadBalancer.Helper helper) {
57 static final class PickFirstBalancer extends LoadBalancer {
|
| LoadBalancer.java | 36 * <p>A LoadBalancer typically implements three interfaces:
38 * <li>{@link LoadBalancer} is the main interface. All methods on it are invoked sequentially
40 * of subchannels' connectivity states, and the channel's request for the LoadBalancer to
44 * <li>{@link Factory Factory} creates a new {@link LoadBalancer} instance.
48 * Factory}. It provides functionalities that a {@code LoadBalancer} implementation would typically
54 * callback methods on the {@link LoadBalancer} interface, thus the balancer implementation doesn't
66 * run callbacks under a lock, e.g., the transport lock of OkHttp. If your LoadBalancer has a
69 * of deadlock. Generally you wouldn't need any locking in the LoadBalancer.</li>
78 * <p>A {@link LoadBalancer} keeps states like the latest addresses from NameResolver, the
85 * its own state, and should not mutate or re-acquire the states of the LoadBalancer. This way th
[all...] |
| ManagedChannelBuilder.java | 218 * Provides a custom {@link LoadBalancer.Factory} for the channel.
231 public abstract T loadBalancerFactory(LoadBalancer.Factory loadBalancerFactory);
275 * LoadBalancer. A new RPC would take the channel out of idle mode. A channel starts in idle mode.
|
| ForwardingChannelBuilder.java | 125 public T loadBalancerFactory(LoadBalancer.Factory loadBalancerFactory) {
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| AutoConfiguredLoadBalancerFactoryTest.java | 27 import io.grpc.LoadBalancer;
28 import io.grpc.LoadBalancer.Helper;
29 import io.grpc.LoadBalancer.Subchannel;
30 import io.grpc.LoadBalancer.SubchannelPicker;
59 LoadBalancer lb = lbf.newLoadBalancer(new TestHelper());
128 LoadBalancer oldDelegate = lb.getDelegate();
194 LoadBalancer.Factory factory =
208 LoadBalancer.Factory factory = AutoConfiguredLoadBalancer.decideLoadBalancerFactory(
223 LoadBalancer.Factory factory = AutoConfiguredLoadBalancer.decideLoadBalancerFactory(
238 LoadBalancer.Factory factory = AutoConfiguredLoadBalancer.decideLoadBalancerFactory
[all...] |
| AbstractManagedChannelImplBuilderTest.java | 36 import io.grpc.LoadBalancer;
131 LoadBalancer.Factory loadBalancerFactory = mock(LoadBalancer.Factory.class);
138 LoadBalancer.Factory defaultValue = builder.loadBalancerFactory;
139 builder.loadBalancerFactory(mock(LoadBalancer.Factory.class));
146 directAddressBuilder.loadBalancerFactory(mock(LoadBalancer.Factory.class));
|
| ManagedChannelImplIdlenessTest.java | 41 import io.grpc.LoadBalancer;
42 import io.grpc.LoadBalancer.Helper;
43 import io.grpc.LoadBalancer.PickResult;
44 import io.grpc.LoadBalancer.PickSubchannelArgs;
45 import io.grpc.LoadBalancer.Subchannel;
46 import io.grpc.LoadBalancer.SubchannelPicker;
104 @Mock private LoadBalancer mockLoadBalancer;
105 @Mock private LoadBalancer.Factory mockLoadBalancerFactory;
184 // Simulate new address resolved to make sure the LoadBalancer is correctly linked to
264 // Assume LoadBalancer has received an address, then create a subchannel
[all...] |
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| RoundRobinLoadBalancerFactory.java | 35 import io.grpc.LoadBalancer;
36 import io.grpc.LoadBalancer.PickResult;
37 import io.grpc.LoadBalancer.PickSubchannelArgs;
38 import io.grpc.LoadBalancer.Subchannel;
39 import io.grpc.LoadBalancer.SubchannelPicker;
65 * A {@link LoadBalancer} that provides round-robin load balancing mechanism over the
71 public final class RoundRobinLoadBalancerFactory extends LoadBalancer.Factory {
98 public LoadBalancer newLoadBalancer(LoadBalancer.Helper helper) {
103 static final class RoundRobinLoadBalancer extends LoadBalancer {
[all...] |
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| LoadBalancerTest.java | 23 import io.grpc.LoadBalancer.PickResult;
24 import io.grpc.LoadBalancer.Subchannel;
33 /** Unit tests for the inner classes in {@link LoadBalancer}. */
202 private static class NoopHelper extends LoadBalancer.Helper {
210 ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker) {}
223 private static class EmptySubchannel extends LoadBalancer.Subchannel {
|
| PickFirstLoadBalancerTest.java | 37 import io.grpc.LoadBalancer.Helper;
38 import io.grpc.LoadBalancer.PickResult;
39 import io.grpc.LoadBalancer.PickSubchannelArgs;
40 import io.grpc.LoadBalancer.Subchannel;
41 import io.grpc.LoadBalancer.SubchannelPicker;
60 private PickFirstBalancer loadBalancer;
75 @Mock // This LoadBalancer doesn't use any of the arg fields, as verified in tearDown().
92 loadBalancer = (PickFirstBalancer) PickFirstBalancerFactory.getInstance().newLoadBalancer(
103 loadBalancer.handleResolvedAddressGroups(servers, affinity);
117 loadBalancer.handleResolvedAddressGroups(servers, affinity)
[all...] |
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| RoundRobinLoadBalancerTest.java | 53 import io.grpc.LoadBalancer;
54 import io.grpc.LoadBalancer.Helper;
55 import io.grpc.LoadBalancer.PickResult;
56 import io.grpc.LoadBalancer.PickSubchannelArgs;
57 import io.grpc.LoadBalancer.Subchannel;
58 import io.grpc.LoadBalancer.SubchannelPicker;
92 private RoundRobinLoadBalancer loadBalancer;
107 @Mock // This LoadBalancer doesn't use any of the arg fields, as verified in tearDown().
134 loadBalancer = (RoundRobinLoadBalancer) RoundRobinLoadBalancerFactory.getInstance()
146 loadBalancer.handleResolvedAddressGroups(servers, affinity)
[all...] |
| /external/grpc-grpc/test/cpp/client/ |
| client_channel_stress_test.cc | 51 using grpc::lb::v1::LoadBalancer;
66 class BalancerServiceImpl : public LoadBalancer::Service {
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| CachedSubchannelPoolTest.java | 35 import io.grpc.LoadBalancer.Helper;
36 import io.grpc.LoadBalancer.Subchannel;
|
