com.google.api.gax.retrying.RetrySettings.getRetryDelayMultiplier()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(7.3k)|赞(0)|评价(0)|浏览(76)

本文整理了Java中com.google.api.gax.retrying.RetrySettings.getRetryDelayMultiplier方法的一些代码示例,展示了RetrySettings.getRetryDelayMultiplier的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RetrySettings.getRetryDelayMultiplier方法的具体详情如下:
包路径:com.google.api.gax.retrying.RetrySettings
类名称:RetrySettings
方法名:getRetryDelayMultiplier

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());

相关文章