Home
last modified time | relevance | path

Searched refs:LoadBalancer (Results 1 – 25 of 36) sorted by relevance

12

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactory.java24 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) { in newLoadBalancer()
53 private static final class NoopLoadBalancer extends LoadBalancer {
70 static final class AutoConfiguredLoadBalancer extends LoadBalancer {
72 private LoadBalancer delegate;
[all …]
DAbstractSubchannel.java22 import io.grpc.LoadBalancer;
29 abstract class AbstractSubchannel extends LoadBalancer.Subchannel {
DOobChannel.java39 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;
DDelayedClientTransport.java26 import io.grpc.LoadBalancer.PickResult;
27 import io.grpc.LoadBalancer.PickSubchannelArgs;
28 import io.grpc.LoadBalancer.SubchannelPicker;
DManagedChannelImpl.java53 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;
1009 private class LbHelperImpl extends LoadBalancer.Helper {
1010 LoadBalancer lb;
1144 LoadBalancer.Subchannel subchannel, List<EquivalentAddressGroup> addrs) { in updateSubchannelAddresses()
DAbstractManagedChannelImplBuilder.java31 import io.grpc.LoadBalancer;
118 @Nullable LoadBalancer.Factory loadBalancerFactory;
239 public final T loadBalancerFactory(LoadBalancer.Factory loadBalancerFactory) { in loadBalancerFactory()
DPickSubchannelArgsImpl.java23 import io.grpc.LoadBalancer.PickSubchannelArgs;
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DPickFirstBalancerFactory.java25 import io.grpc.LoadBalancer.PickResult;
26 import io.grpc.LoadBalancer.PickSubchannelArgs;
27 import io.grpc.LoadBalancer.Subchannel;
28 import io.grpc.LoadBalancer.SubchannelPicker;
37 public final class PickFirstBalancerFactory extends LoadBalancer.Factory {
52 public LoadBalancer newLoadBalancer(LoadBalancer.Helper helper) { in newLoadBalancer()
57 static final class PickFirstBalancer extends LoadBalancer {
DLoadBalancer.java101 public abstract class LoadBalancer { class
666 public abstract LoadBalancer newLoadBalancer(Helper helper); in newLoadBalancer()
DManagedChannelBuilder.java231 public abstract T loadBalancerFactory(LoadBalancer.Factory loadBalancerFactory); in loadBalancerFactory()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactoryTest.java27 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()); in newLoadBalancer_isAuto()
128 LoadBalancer oldDelegate = lb.getDelegate(); in handleResolvedAddressGroups_keepOldBalancer()
194 LoadBalancer.Factory factory = in decideLoadBalancerFactory_noBalancerAddresses_noServiceConfig_pickFirst()
208 LoadBalancer.Factory factory = AutoConfiguredLoadBalancer.decideLoadBalancerFactory( in decideLoadBalancerFactory_oneBalancer_noServiceConfig_grpclb()
223 LoadBalancer.Factory factory = AutoConfiguredLoadBalancer.decideLoadBalancerFactory( in decideLoadBalancerFactory_grpclbOverridesServiceConfig()
238 LoadBalancer.Factory factory = AutoConfiguredLoadBalancer.decideLoadBalancerFactory( in decideLoadBalancerFactory_serviceConfigOverridesDefault()
[all …]
DManagedChannelImplIdlenessTest.java41 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;
DAbstractManagedChannelImplBuilderTest.java36 import io.grpc.LoadBalancer;
131 LoadBalancer.Factory loadBalancerFactory = mock(LoadBalancer.Factory.class); in loadBalancerFactory_normal()
138 LoadBalancer.Factory defaultValue = builder.loadBalancerFactory; in loadBalancerFactory_null()
139 builder.loadBalancerFactory(mock(LoadBalancer.Factory.class)); in loadBalancerFactory_null()
146 directAddressBuilder.loadBalancerFactory(mock(LoadBalancer.Factory.class)); in loadBalancerFactory_notAllowedWithDirectAddress()
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbLoadBalancerFactory.java20 import io.grpc.LoadBalancer;
33 public class GrpclbLoadBalancerFactory extends LoadBalancer.Factory {
45 public LoadBalancer newLoadBalancer(LoadBalancer.Helper helper) { in newLoadBalancer()
DSubchannelPool.java21 import io.grpc.LoadBalancer.Helper;
22 import io.grpc.LoadBalancer.Subchannel;
DGrpclbLoadBalancer.java27 import io.grpc.LoadBalancer;
45 class GrpclbLoadBalancer extends LoadBalancer implements InternalWithLogId {
DCachedSubchannelPool.java25 import io.grpc.LoadBalancer.Helper;
26 import io.grpc.LoadBalancer.Subchannel;
DGrpclbState.java37 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;
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java35 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;
71 public final class RoundRobinLoadBalancerFactory extends LoadBalancer.Factory {
98 public LoadBalancer newLoadBalancer(LoadBalancer.Helper helper) { in newLoadBalancer()
103 static final class RoundRobinLoadBalancer extends LoadBalancer {
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DLoadBalancerTest.java23 import io.grpc.LoadBalancer.PickResult;
24 import io.grpc.LoadBalancer.Subchannel;
202 private static class NoopHelper extends LoadBalancer.Helper {
210 ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker) {} in updateBalancingState()
223 private static class EmptySubchannel extends LoadBalancer.Subchannel {
DPickFirstLoadBalancerTest.java37 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;
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java53 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;
326 LoadBalancer.PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithNoChannels()
349 LoadBalancer.PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithActiveChannels()
353 LoadBalancer.PickResult pickResult2 = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithActiveChannels()
/external/grpc-grpc-java/grpclb/
Dbuild.gradle1 description = "gRPC: GRPCLB LoadBalancer plugin"
/external/grpc-grpc/test/cpp/client/
Dclient_channel_stress_test.cc51 using grpc::lb::v1::LoadBalancer;
66 class BalancerServiceImpl : public LoadBalancer::Service {
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DCachedSubchannelPoolTest.java35 import io.grpc.LoadBalancer.Helper;
36 import io.grpc.LoadBalancer.Subchannel;

12