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.

Sign up for GitHub

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

Jump to bottom

fix: Set publish timeouts to be consistent with desired values #820

Merged
merged 18 commits into from Aug 31, 2021
Merged

fix: Set publish timeouts to be consistent with desired values #820

Changes from all commits
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
2b50adb
feat: Add flow control support to publisher
kamalaboulhosn Mar 24, 2020
6bb47bc
make suggested fixes
kamalaboulhosn Mar 25, 2020
0ffda7c
Merge remote-tracking branch 'upstream/master'
kamalaboulhosn May 2, 2020
9c113c3
chore: Remove note that ordering keys requires enablements.
kamalaboulhosn May 2, 2020
2a295c1
Merge remote-tracking branch 'upstream/master'
kamalaboulhosn Jun 21, 2020
6947740
feat: Add support for server-side flow control
kamalaboulhosn Jun 21, 2020
fb08aa3
Revert "chore: Remove note that ordering keys requires enablements."
kamalaboulhosn Jun 21, 2020
304059f
Merge remote-tracking branch 'upstream/master'
kamalaboulhosn Jun 24, 2020
c9c2028
fix: Fix import order
kamalaboulhosn Jun 24, 2020
7b50aa1
Merge remote-tracking branch 'upstream/master' into master
kamalaboulhosn Jul 23, 2020
78ab82d
fix: Make error message more clear about where ordering must be enabl…
kamalaboulhosn Jul 23, 2020
dc62fb7
Merge remote-tracking branch 'upstream/master'
kamalaboulhosn Sep 27, 2020
8b73467
fix: Ensure that messages that are in pending batches for an ordering…
kamalaboulhosn Sep 27, 2020
75dc73e
Merge remote-tracking branch 'upstream/master'
kamalaboulhosn Sep 29, 2020
8be37d7
fix: Only check keyHasError if ordering keys is non-empty
kamalaboulhosn Sep 29, 2020
f2cded5
Merge remote-tracking branch 'upstream/master'
kamalaboulhosn Jul 19, 2021
e1f347b
Merge remote-tracking branch 'upstream/master'
kamalaboulhosn Aug 31, 2021
83342f5
fix: Set publish timeouts to be consistent with desired values
kamalaboulhosn Aug 31, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
13 changes: 8 additions & 5 deletions google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java
View file
Open in desktop
Expand Up @@ -657,8 +657,11 @@ public static final class Builder {
static final long DEFAULT_REQUEST_BYTES_THRESHOLD = 1000L; // 1 kB
static final Duration DEFAULT_DELAY_THRESHOLD = Duration.ofMillis(1);
private static final Duration DEFAULT_INITIAL_RPC_TIMEOUT = Duration.ofSeconds(5);
private static final Duration DEFAULT_MAX_RPC_TIMEOUT = Duration.ofSeconds(600);
private static final Duration DEFAULT_MAX_RPC_TIMEOUT = Duration.ofSeconds(60);
private static final Duration DEFAULT_TOTAL_TIMEOUT = Duration.ofSeconds(600);
private static final Duration DEFAULT_INITIAL_RETRY_DELAY = Duration.ofMillis(100);
private static final Duration DEFAULT_MAX_RETRY_DELAY = Duration.ofSeconds(60);
private static final double DEFAULT_MULTIPLIER = 1.3;
static final BatchingSettings DEFAULT_BATCHING_SETTINGS =
BatchingSettings.newBuilder()
.setDelayThreshold(DEFAULT_DELAY_THRESHOLD)
Expand All @@ -672,11 +675,11 @@ public static final class Builder {
static final RetrySettings DEFAULT_RETRY_SETTINGS =
RetrySettings.newBuilder()
.setTotalTimeout(DEFAULT_TOTAL_TIMEOUT)
.setInitialRetryDelay(Duration.ofMillis(100))
.setRetryDelayMultiplier(1.3)
.setMaxRetryDelay(Duration.ofSeconds(60))
.setInitialRetryDelay(DEFAULT_INITIAL_RETRY_DELAY)
.setRetryDelayMultiplier(DEFAULT_MULTIPLIER)
.setMaxRetryDelay(DEFAULT_MAX_RETRY_DELAY)
.setInitialRpcTimeout(DEFAULT_INITIAL_RPC_TIMEOUT)
.setRpcTimeoutMultiplier(1)
.setRpcTimeoutMultiplier(DEFAULT_MULTIPLIER)
.setMaxRpcTimeout(DEFAULT_MAX_RPC_TIMEOUT)
.build();
static final boolean DEFAULT_ENABLE_MESSAGE_ORDERING = false;
Expand Down