feat(pubsub): implement publish hedging to reduce tail latency - #13735

Open

tonyyyycui wants to merge 36 commits into

googleapis:mainfrom

tonyyyycui:publish-hedging-settings

Commits on Jul 13, 2026

Add hedgeSettings with configurable hedgeDelay
Tony Cui
committed
61d0b60
Add HedgeTokenBucket class to allow for token operations
Tony Cui
committed
19afd68
Add publisher integration with HedgeSettings
Tony Cui
committed
49426a9
Restore original @Ignore annotations and code in PublisherImplTest
Tony Cui
committed
22417d1
style(pubsub): fix checkstyle violations in HedgeSettings
Tony Cui
committed
91706a2
style(pubsub): fix formatting and checkstyle violations in HedgeSettings and tests
Tony Cui
committed
bd76ede
Merge branch 'main' into publish-hedging-settings
tonyyyycui
authored
61aef08

Commits on Jul 20, 2026

Resolve git comments related to access modifiers and constraints
Tony Cui
committed
227f808
Add CancellationSharer and HedgedRequest helper classes
Tony Cui
committed
e29eab8
Integrate CancellationSharer and HedgedRequest into Publisher.java. Also add Unit tests
Tony Cui
committed
ed05c60
fix lint
Tony Cui
committed
23b8432
Modifying comment line
Tony Cui
committed
3a23d60

Commits on Jul 27, 2026

Modified default values, added configurable settings to refill ratio and maxtokens, updated tests.
Tony Cui
committed
da4307e
Removed HedgeTokenBucket.java class in favor of using an atomicinteger for hedgeTokenBucket. Also added HEDGE_TOKEN_SCALE.
Tony Cui
committed
336c809
Add documentation for scaling and remove unused getAttemptCount() in CancellationSharer.java
Tony Cui
committed
59a7a09
Added method overloading to handle OTel span for hedged publish events
Tony Cui
committed
79411a8
Verify that the per-RPC timeout is strictly greater than the hedging delay
Tony Cui
committed
e545cd6
Moved static methods in Publisher.java above the builder
Tony Cui
committed
8543d23
Configure empty token bucket and fix naming
Tony Cui
committed
3c48a1a
Change from synchronization to actual lock object for processQueue method
Tony Cui
committed
0929a1b

Commits on Jul 28, 2026

Add header injection for hedged publish requests
Tony Cui
committed
0295144
Cleanup code and fix bug with handling failure attempts in the first rpc call
Tony Cui
committed
c8296f5
Disable retries for failing rpcs when publish hedging
Tony Cui
committed
c8fd6e9

Commits on Jul 30, 2026

Change how cancellationSharer propagates cancellations for different failure codes
Tony Cui
committed
0b88e33
Fixing race condition in unit test setup
Tony Cui
committed
b6af015
Merge branch 'main' into publish-hedging-settings
tonyyyycui
authored
be69b98

Commits on Jul 31, 2026

Modify header to use an integer count instead of a bool
Tony Cui
committed
1a4644f
Merge branch 'publish-hedging-settings' of github.com:tonyyyycui/google-cloud-java into publish-hedging-settings
Tony Cui
committed
e87c26f
Fix lint
Tony Cui
committed
dd288c7

Commits on Aug 4, 2026

Modify scale factor and minimum refillRatio value. Add test annotation to publisher
Tony Cui
committed
8885dc2
Update scale factor, refill ratio constraints, and simplify token bucket operations
Tony Cui
committed
2eb687f
Rename HedgeSettings to HedgingSettings
Tony Cui
committed
100db18
Inline the hedging attempt count headers map creation
Tony Cui
committed
ba05985
Added new subsystem to loggerUtil and adjusted logging usage
Tony Cui
committed
97820e7
Add debugging for token bucket rate limiting
Tony Cui
committed
58a4f70
Add publish end (hedged) event as well
Tony Cui
committed
7361f15