Searched refs:Throttle (Results 1 – 5 of 5) sorted by relevance
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | RetriableStreamTest.java | 56 import io.grpc.internal.RetriableStream.Throttle;
135 @Nullable Throttle throttle) { in RecordedRetriableStream()
179 private RetriableStream<String> newThrottledRetriableStream(Throttle throttle) { in newThrottledRetriableStream()
1192 Throttle throttle = new Throttle(4f, 0.8f); in throttle()
1226 Throttle throttle = new Throttle(4f, 0.8f); in throttledStream_FailWithRetriableStatusCode_WithoutPushback()
1246 Throttle throttle = new Throttle(4f, 0.8f); in throttledStream_FailWithNonRetriableStatusCode_WithoutPushback()
1268 Throttle throttle = new Throttle(4f, 0.8f); in throttledStream_FailWithRetriableStatusCode_WithRetriablePushback()
1291 Throttle throttle = new Throttle(4f, 0.8f); in throttledStream_FailWithNonRetriableStatusCode_WithRetriablePushback()
1320 Throttle throttle = new Throttle(4f, 0.8f); in throttledStream_FailWithRetriableStatusCode_WithNonRetriablePushback()
1342 Throttle throttle = new Throttle(4f, 0.8f); in throttledStream_FailWithNonRetriableStatusCode_WithNonRetriablePushback()
[all …]
|
| D | RetryPolicyTest.java | 33 import io.grpc.internal.RetriableStream.Throttle;
179 Throttle throttle = ServiceConfigUtil.getThrottlePolicy(serviceConfig); in getThrottle()
181 assertEquals(new Throttle(10f, 0.1f), throttle); in getThrottle()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | RetriableStream.java | 78 private final Throttle throttle;
102 @Nullable Throttle throttle) { in RetriableStream()
915 static final class Throttle { class in RetriableStream
938 Throttle(float maxTokens, float tokenRatio) { in Throttle() method in RetriableStream.Throttle
991 if (!(o instanceof Throttle)) { in equals()
994 Throttle that = (Throttle) o; in equals()
|
| D | ServiceConfigUtil.java | 24 import io.grpc.internal.RetriableStream.Throttle;
66 static Throttle getThrottlePolicy(@Nullable Map<String, Object> serviceConfig) { in getThrottlePolicy()
97 return new Throttle(maxTokens, tokenRatio); in getThrottlePolicy()
|
| D | ManagedChannelImpl.java | 64 import io.grpc.internal.RetriableStream.Throttle;
229 private Throttle throttle;
1367 private static Throttle getThrottle(Attributes config) { in getThrottle()
|