本文整理了Java中com.google.api.gax.retrying.RetrySettings.getRetryDelayMultiplier
方法的一些代码示例,展示了RetrySettings.getRetryDelayMultiplier
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RetrySettings.getRetryDelayMultiplier
方法的具体详情如下:
包路径:com.google.api.gax.retrying.RetrySettings
类名称:RetrySettings
方法名:getRetryDelayMultiplier
[英]RetryDelayMultiplier controls the change in retry delay. The retry delay of the previous call is multiplied by the RetryDelayMultiplier to calculate the retry delay for the next call. The default value is 1.0.
[中]RetryDelayMultiplier控制重试延迟的变化。将上一次呼叫的重试延迟乘以RetryDelay乘数,以计算下一次呼叫的重试延迟。默认值为1.0。
代码示例来源:origin: googleapis/google-cloud-java
private void verifyRetrySettings(Set<Code> retryCodes, RetrySettings retrySettings) {
assertThat(retryCodes).containsAllOf(Code.DEADLINE_EXCEEDED, Code.UNAVAILABLE);
assertThat(retrySettings.getTotalTimeout()).isGreaterThan(Duration.ZERO);
assertThat(retrySettings.getInitialRetryDelay()).isGreaterThan(Duration.ZERO);
assertThat(retrySettings.getRetryDelayMultiplier()).isAtLeast(1.0);
assertThat(retrySettings.getMaxRetryDelay()).isGreaterThan(Duration.ZERO);
assertThat(retrySettings.getInitialRpcTimeout()).isGreaterThan(Duration.ZERO);
assertThat(retrySettings.getRpcTimeoutMultiplier()).isAtLeast(1.0);
assertThat(retrySettings.getMaxRpcTimeout()).isGreaterThan(Duration.ZERO);
}
}
代码示例来源:origin: googleapis/google-cloud-java
private void verifyRetrySettingAreSane(Set<Code> retryCodes, RetrySettings retrySettings) {
assertThat(retryCodes).containsAllOf(Code.DEADLINE_EXCEEDED, Code.UNAVAILABLE);
assertThat(retrySettings.getTotalTimeout()).isGreaterThan(Duration.ZERO);
assertThat(retrySettings.getInitialRetryDelay()).isGreaterThan(Duration.ZERO);
assertThat(retrySettings.getRetryDelayMultiplier()).isAtLeast(1.0);
assertThat(retrySettings.getMaxRetryDelay()).isGreaterThan(Duration.ZERO);
assertThat(retrySettings.getInitialRpcTimeout()).isGreaterThan(Duration.ZERO);
assertThat(retrySettings.getRpcTimeoutMultiplier()).isAtLeast(1.0);
assertThat(retrySettings.getMaxRpcTimeout()).isGreaterThan(Duration.ZERO);
}
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testReadRowsSettings() {
ServerStreamingCallSettings.Builder<ReadRowsRequest, ReadRowsResponse> builder =
EnhancedBigQueryStorageStubSettings.newBuilder().readRowsSettings();
assertThat(builder.getRetryableCodes()).containsAllOf(Code.DEADLINE_EXCEEDED, Code.UNAVAILABLE);
RetrySettings retrySettings = builder.getRetrySettings();
assertThat(retrySettings.getInitialRetryDelay()).isEqualTo(Duration.ofMillis(100L));
assertThat(retrySettings.getRetryDelayMultiplier()).isWithin(1e-6).of(1.3);
assertThat(retrySettings.getMaxRetryDelay()).isEqualTo(Duration.ofMinutes(1L));
assertThat(retrySettings.getInitialRpcTimeout()).isEqualTo(Duration.ofDays(1L));
assertThat(retrySettings.getRpcTimeoutMultiplier()).isWithin(1e-6).of(1.0);
assertThat(retrySettings.getMaxRpcTimeout()).isEqualTo(Duration.ofDays(1L));
assertThat(retrySettings.getTotalTimeout()).isEqualTo(Duration.ofDays(1L));
assertThat(builder.getIdleTimeout()).isEqualTo(Duration.ZERO);
}
代码示例来源:origin: com.google.api/gax
public RetrySettings build() {
RetrySettings params = autoBuild();
if (params.getTotalTimeout().toMillis() < 0) {
throw new IllegalStateException("total timeout must not be negative");
}
if (params.getInitialRetryDelay().toMillis() < 0) {
throw new IllegalStateException("initial retry delay must not be negative");
}
if (params.getRetryDelayMultiplier() < 1.0) {
throw new IllegalStateException("retry delay multiplier must be at least 1");
}
if (params.getMaxRetryDelay().compareTo(params.getInitialRetryDelay()) < 0) {
throw new IllegalStateException("max retry delay must not be shorter than initial delay");
}
if (params.getMaxAttempts() < 0) {
throw new IllegalStateException("max attempts must be non-negative");
}
if (params.getInitialRpcTimeout().toMillis() < 0) {
throw new IllegalStateException("initial rpc timeout must not be negative");
}
if (params.getMaxRpcTimeout().compareTo(params.getInitialRpcTimeout()) < 0) {
throw new IllegalStateException("max rpc timeout must not be shorter than initial timeout");
}
if (params.getRpcTimeoutMultiplier() < 1.0) {
throw new IllegalStateException("rpc timeout multiplier must be at least 1");
}
return params;
}
代码示例来源:origin: googleapis/gax-java
public RetrySettings build() {
RetrySettings params = autoBuild();
if (params.getTotalTimeout().toMillis() < 0) {
throw new IllegalStateException("total timeout must not be negative");
}
if (params.getInitialRetryDelay().toMillis() < 0) {
throw new IllegalStateException("initial retry delay must not be negative");
}
if (params.getRetryDelayMultiplier() < 1.0) {
throw new IllegalStateException("retry delay multiplier must be at least 1");
}
if (params.getMaxRetryDelay().compareTo(params.getInitialRetryDelay()) < 0) {
throw new IllegalStateException("max retry delay must not be shorter than initial delay");
}
if (params.getMaxAttempts() < 0) {
throw new IllegalStateException("max attempts must be non-negative");
}
if (params.getInitialRpcTimeout().toMillis() < 0) {
throw new IllegalStateException("initial rpc timeout must not be negative");
}
if (params.getMaxRpcTimeout().compareTo(params.getInitialRpcTimeout()) < 0) {
throw new IllegalStateException("max rpc timeout must not be shorter than initial timeout");
}
if (params.getRpcTimeoutMultiplier() < 1.0) {
throw new IllegalStateException("rpc timeout multiplier must be at least 1");
}
return params;
}
代码示例来源:origin: google/java-photoslibrary
if (previousDelayMillis.isPresent()) {
delayMillis =
(long) (previousDelayMillis.getAsLong() * retrySettings.getRetryDelayMultiplier());
代码示例来源:origin: googleapis/gax-java
@Test
public void retrySettingsMerge() {
RetrySettings.Builder builder =
RetrySettings.newBuilder()
.setTotalTimeout(Duration.ofMillis(45000))
.setInitialRpcTimeout(Duration.ofMillis(2000))
.setRpcTimeoutMultiplier(1.5)
.setMaxRpcTimeout(Duration.ofMillis(30000))
.setInitialRetryDelay(Duration.ofMillis(100))
.setRetryDelayMultiplier(1.2)
.setMaxRetryDelay(Duration.ofMillis(1000));
RetrySettings.Builder mergedBuilder = RetrySettings.newBuilder();
mergedBuilder.merge(builder);
RetrySettings settingsA = builder.build();
RetrySettings settingsB = mergedBuilder.build();
Truth.assertThat(settingsA.getTotalTimeout()).isEqualTo(settingsB.getTotalTimeout());
Truth.assertThat(settingsA.getInitialRetryDelay()).isEqualTo(settingsB.getInitialRetryDelay());
Truth.assertThat(settingsA.getRpcTimeoutMultiplier())
.isWithin(0)
.of(settingsB.getRpcTimeoutMultiplier());
Truth.assertThat(settingsA.getMaxRpcTimeout()).isEqualTo(settingsB.getMaxRpcTimeout());
Truth.assertThat(settingsA.getInitialRetryDelay()).isEqualTo(settingsB.getInitialRetryDelay());
Truth.assertThat(settingsA.getRetryDelayMultiplier())
.isWithin(0)
.of(settingsB.getRetryDelayMultiplier());
Truth.assertThat(settingsA.getMaxRetryDelay()).isEqualTo(settingsB.getMaxRetryDelay());
}
代码示例来源:origin: com.google.api/gax
if (prevSettings.getAttemptCount() > 0) {
newRetryDelay =
(long) (settings.getRetryDelayMultiplier() * prevSettings.getRetryDelay().toMillis());
newRetryDelay = Math.min(newRetryDelay, settings.getMaxRetryDelay().toMillis());
代码示例来源:origin: googleapis/gax-java
if (prevSettings.getAttemptCount() > 0) {
newRetryDelay =
(long) (settings.getRetryDelayMultiplier() * prevSettings.getRetryDelay().toMillis());
newRetryDelay = Math.min(newRetryDelay, settings.getMaxRetryDelay().toMillis());
内容来源于网络,如有侵权,请联系作者删除!