Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: use PingAndWarm request for channel priming #1179

Merged
merged 7 commits into from
Jul 19, 2022
Prev Previous commit
Next Next commit
add some comments
  • Loading branch information
mutianf committed Jul 19, 2022
commit 411646e95820859fcfa801ab95d34032baf4de15
Original file line number Diff line number Diff line change
Expand Up @@ -95,8 +95,6 @@ public class EnhancedBigtableStubSettings extends StubSettings<EnhancedBigtableS
private static final Set<Code> IDEMPOTENT_RETRY_CODES =
ImmutableSet.of(Code.DEADLINE_EXCEEDED, Code.UNAVAILABLE);

private static Duration PRIME_REQUEST_TIMEOUT = Duration.ofSeconds(30);

// Copy of default retrying settings in the yaml
private static final RetrySettings IDEMPOTENT_RETRY_SETTINGS =
RetrySettings.newBuilder()
Expand All @@ -116,6 +114,9 @@ public class EnhancedBigtableStubSettings extends StubSettings<EnhancedBigtableS
private static final Set<Code> READ_ROWS_RETRY_CODES =
ImmutableSet.<Code>builder().addAll(IDEMPOTENT_RETRY_CODES).add(Code.ABORTED).build();

// Priming request should have a shorter timeout
private static Duration PRIME_REQUEST_TIMEOUT = Duration.ofSeconds(30);

private static final RetrySettings READ_ROWS_RETRY_SETTINGS =
RetrySettings.newBuilder()
.setInitialRetryDelay(Duration.ofMillis(10))
Expand Down