Skip to content
This repository was archived by the owner on Jun 18, 2025. It is now read-only.

fix: invoke reconnect when readInternal return error #188

Merged
YoEight merged 13 commits into from
Nov 12, 2024
Merged

fix: invoke reconnect when readInternal return error #188

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
a77b25e
fix: invoke reconnect when readInternal return error
itgram Oct 22, 2024
6f30030
add unit test to read stream after cluster rebalance
itgram Oct 23, 2024
76a20e9
adjust the test
itgram Oct 24, 2024
5216f04
wait for the leader to be elected
itgram Oct 24, 2024
01bfadf
revert the test case
itgram Oct 27, 2024
d31ae7f
correct the test function
itgram Oct 29, 2024
21cd60d
check for member is alive
itgram Oct 29, 2024
f4c2232
Retry reading the stream a specific number of times
itgram Oct 29, 2024
061c1c9
log retries count
itgram Oct 29, 2024
5bb37c6
fix retries count
itgram Oct 29, 2024
7e6927a
isolate the rebalance tests to avoid conflict with other tests
itgram Oct 29, 2024
106d8c1
Merge branch 'master' into master
itgram Nov 12, 2024
8da4cb1
Update esdb/client.go
itgram Nov 12, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Update esdb/client.go 
Co-authored-by: Yo Eight <yo.eight@gmail.com>
  • Loading branch information
@itgram @YoEight
itgram and YoEight authored Nov 12, 2024
commit 8da4cb119409c8a6193ebb71f6bd0bc2519df52b
2 changes: 1 addition & 1 deletion esdb/client.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -762,7 +762,7 @@ func readInternal(
if err != nil {
defer cancel()

err = client.grpcClient.handleError(handle, headers, trailers, err)
err = client.grpcClient.handleError(handle, trailers, err)
return nil, fmt.Errorf("could not construct read operation. Reason: %w", err)
}

Expand Down