Searched refs:balanceLoad (Results 1 – 3 of 3) sorted by relevance
184 public StreamObserver<LoadBalanceRequest> balanceLoad( in setUp()406 verify(mockLbService).balanceLoad(lbResponseObserverCaptor.capture()); in loadReporting()563 verify(mockLbService, times(2)).balanceLoad(lbResponseObserverCaptor.capture()); in loadReporting()627 verify(mockLbService).balanceLoad(lbResponseObserverCaptor.capture()); in abundantInitialResponse()657 verify(mockLbService).balanceLoad(lbResponseObserverCaptor.capture()); in raceBetweenLoadReportingAndLbStreamClosure()750 verify(mockLbService).balanceLoad(lbResponseObserverCaptor.capture()); in nameResolutionFailsThenRecoverToGrpclb()764 verify(mockLbService).balanceLoad(lbResponseObserverCaptor.capture()); in grpclbThenNameResolutionFails()851 verify(mockLbService).balanceLoad(lbResponseObserverCaptor.capture()); in grpclbWorking()1062 verify(mockLbService).balanceLoad(lbResponseObserverCaptor.capture()); in subtestGrpclbFallbackInitialTimeout()1094 verify(mockLbService, times(2)).balanceLoad(lbResponseObserverCaptor.capture()); in subtestGrpclbFallbackInitialTimeout()[all …]
94 public io.grpc.stub.StreamObserver<io.grpc.lb.v1.LoadBalanceRequest> balanceLoad( in balanceLoad() method in LoadBalancerGrpc.LoadBalancerImplBase135 public io.grpc.stub.StreamObserver<io.grpc.lb.v1.LoadBalanceRequest> balanceLoad( in balanceLoad() method in LoadBalancerGrpc.LoadBalancerStub210 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.balanceLoad( in invoke()
486 lbRequestWriter = stub.withWaitForReady().balanceLoad(this); in start()