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

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

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

RetrySettings.getMaxRetryDelay介绍

[英]MaxRetryDelay puts a limit on the value of the retry delay, so that the RetryDelayMultiplier can't increase the retry delay higher than this amount. The default value is Duration.ZERO.
[中]MaxRetryDelay对重试延迟的值进行了限制，因此RetryDelayMultiplier不能将重试延迟增加到高于此值的值。默认值为持续时间。零

代码示例

代码示例来源：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: googleapis/google-cloud-java

@Test
 public void testCreateFromStream() {
  RemoteStorageHelper helper = RemoteStorageHelper.create(PROJECT_ID, JSON_KEY_STREAM);
  StorageOptions options = helper.getOptions();
  assertEquals(PROJECT_ID, options.getProjectId());
  assertEquals(60000, ((HttpTransportOptions) options.getTransportOptions()).getConnectTimeout());
  assertEquals(60000, ((HttpTransportOptions) options.getTransportOptions()).getReadTimeout());
  assertEquals(10, options.getRetrySettings().getMaxAttempts());
  assertEquals(Duration.ofMillis(30000), options.getRetrySettings().getMaxRetryDelay());
  assertEquals(Duration.ofMillis(120000), options.getRetrySettings().getTotalTimeout());
  assertEquals(Duration.ofMillis(250), options.getRetrySettings().getInitialRetryDelay());
 }
}

代码示例来源：origin: googleapis/google-cloud-java

@Test
public void testCreateFromStream() {
 RemoteComputeHelper helper = RemoteComputeHelper.create(PROJECT_ID, JSON_KEY_STREAM);
 ComputeOptions options = helper.getOptions();
 assertEquals(PROJECT_ID, options.getProjectId());
 assertEquals(60000, ((HttpTransportOptions) options.getTransportOptions()).getConnectTimeout());
 assertEquals(60000, ((HttpTransportOptions) options.getTransportOptions()).getReadTimeout());
 assertEquals(10, options.getRetrySettings().getMaxAttempts());
 assertEquals(Duration.ofMillis(30000), options.getRetrySettings().getMaxRetryDelay());
 assertEquals(Duration.ofMillis(120000), options.getRetrySettings().getTotalTimeout());
 assertEquals(Duration.ofMillis(250), options.getRetrySettings().getInitialRetryDelay());
}

代码示例来源：origin: googleapis/google-cloud-java

@Test
 public void testCreateFromStream() {
  RemoteBigQueryHelper helper = RemoteBigQueryHelper.create(PROJECT_ID, JSON_KEY_STREAM);
  BigQueryOptions options = helper.getOptions();
  assertEquals(PROJECT_ID, options.getProjectId());
  assertEquals(60000, ((HttpTransportOptions) options.getTransportOptions()).getConnectTimeout());
  assertEquals(60000, ((HttpTransportOptions) options.getTransportOptions()).getReadTimeout());
  assertEquals(10, options.getRetrySettings().getMaxAttempts());
  assertEquals(Duration.ofMillis(30000), options.getRetrySettings().getMaxRetryDelay());
  assertEquals(Duration.ofMillis(120000), options.getRetrySettings().getTotalTimeout());
  assertEquals(Duration.ofMillis(250), options.getRetrySettings().getInitialRetryDelay());
 }
}

代码示例来源：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: 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: google/java-photoslibrary

Math.min(delayMillis, retrySettings.getMaxRetryDelay().get(MILLIS));
if (retrySettings.isJittered()) {
 actualDelayMillis = ThreadLocalRandom.current().nextLong(actualDelayMillis);

代码示例来源：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: googleapis/gax-java

newRetryDelay =
  (long) (settings.getRetryDelayMultiplier() * prevSettings.getRetryDelay().toMillis());
newRetryDelay = Math.min(newRetryDelay, settings.getMaxRetryDelay().toMillis());

代码示例来源：origin: com.google.api/gax

newRetryDelay =
  (long) (settings.getRetryDelayMultiplier() * prevSettings.getRetryDelay().toMillis());
newRetryDelay = Math.min(newRetryDelay, settings.getMaxRetryDelay().toMillis());

内容来源于网络，如有侵权，请联系作者删除！

RetrySettings

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com