Home
last modified time | relevance | path

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

12

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactory.java27 import io.grpc.LoadBalancer;
28 import io.grpc.LoadBalancer.Helper;
29 import io.grpc.LoadBalancer.PickResult;
30 import io.grpc.LoadBalancer.PickSubchannelArgs;
31 import io.grpc.LoadBalancer.SubchannelPicker;
41 final class AutoConfiguredLoadBalancerFactory extends LoadBalancer.Factory {
62 public LoadBalancer newLoadBalancer(Helper helper) { in newLoadBalancer()
66 private static final class NoopLoadBalancer extends LoadBalancer {
83 static final class AutoConfiguredLoadBalancer extends LoadBalancer {
85 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;
DAbstractManagedChannelImplBuilder.java31 import io.grpc.LoadBalancer;
118 @Nullable LoadBalancer.Factory loadBalancerFactory;
239 public final T loadBalancerFactory(LoadBalancer.Factory loadBalancerFactory) { in loadBalancerFactory()
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;
998 private class LbHelperImpl extends LoadBalancer.Helper {
999 LoadBalancer lb;
1139 LoadBalancer.Subchannel subchannel, List<EquivalentAddressGroup> addrs) { in updateSubchannelAddresses()
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
672 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/util/
DForwardingLoadBalancerHelperTest.java23 import io.grpc.LoadBalancer;
36 private final LoadBalancer.Helper mockDelegate = mock(LoadBalancer.Helper.class);
40 protected LoadBalancer.Helper delegate() { in delegate()
49 LoadBalancer.Helper.class, in allMethodsForwarded()
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/core/src/test/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactoryTest.java30 import io.grpc.LoadBalancer;
31 import io.grpc.LoadBalancer.Helper;
32 import io.grpc.LoadBalancer.Subchannel;
33 import io.grpc.LoadBalancer.SubchannelPicker;
63 LoadBalancer lb = lbf.newLoadBalancer(new TestHelper()); in newLoadBalancer_isAuto()
132 LoadBalancer oldDelegate = lb.getDelegate(); in handleResolvedAddressGroups_keepOldBalancer()
198 LoadBalancer.Factory factory = in decideLoadBalancerFactory_noBalancerAddresses_noServiceConfig_pickFirst()
212 LoadBalancer.Factory factory = AutoConfiguredLoadBalancer.decideLoadBalancerFactory( in decideLoadBalancerFactory_oneBalancer_noServiceConfig_grpclb()
227 LoadBalancer.Factory factory = AutoConfiguredLoadBalancer.decideLoadBalancerFactory( in decideLoadBalancerFactory_grpclbOverridesServiceConfig()
242 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;
DCachedSubchannelPool.java25 import io.grpc.LoadBalancer.Helper;
26 import io.grpc.LoadBalancer.Subchannel;
DGrpclbLoadBalancer.java27 import io.grpc.LoadBalancer;
45 class GrpclbLoadBalancer extends LoadBalancer implements InternalWithLogId {
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/
DForwardingLoadBalancerHelper.java24 import io.grpc.LoadBalancer.Subchannel;
25 import io.grpc.LoadBalancer.SubchannelPicker;
26 import io.grpc.LoadBalancer;
32 public abstract class ForwardingLoadBalancerHelper extends LoadBalancer.Helper {
36 protected abstract LoadBalancer.Helper delegate(); in delegate()
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/grpclb/
Dbuild.gradle1 description = "gRPC: GRPCLB LoadBalancer plugin"

12