-
Notifications
You must be signed in to change notification settings - Fork 217
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
pd http: support api to get store min resolved ts #793
Conversation
88d7fa8
to
acb6745
Compare
Signed-off-by: husharp <[email protected]>
acb6745
to
1648fc9
Compare
Signed-off-by: husharp <[email protected]>
Signed-off-by: husharp <[email protected]>
Signed-off-by: husharp <[email protected]>
Signed-off-by: husharp <[email protected]>
036d5b5
to
b2d9fe6
Compare
integration_tests/raw/api_test.go
Outdated
return c.Client.CloseAddr(addr) | ||
} | ||
|
||
func (s *apiTestSuite) TestGetStoreMinResolvedTS() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I don't think it's proper to put resolved_ts
test inside integration_tests/raw/api_test.go
since it's for the RawKV API testing.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
move to pd_api_test
file
Signed-off-by: husharp <[email protected]>
Signed-off-by: husharp <[email protected]>
@Defined2014 PTAL, thx! |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Signed-off-by: husharp <[email protected]>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The rest LGTM.
return | ||
// Try to get the minimum resolved timestamp of the store from PD. | ||
if s.pdHttpClient != nil { | ||
safeTS, err = s.pdHttpClient.GetStoreMinResolvedTS(ctx, storeID) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We could add a debug log to output safeTS
and err
when it's not nil.
Signed-off-by: husharp <[email protected]>
e708d8a
to
6e4bfa5
Compare
Signed-off-by: husharp <[email protected]>
Co-authored-by: MyonKeminta <[email protected]> Co-authored-by: disksing <[email protected]> Co-authored-by: MyonKeminta <[email protected]> Co-authored-by: Violin <[email protected]> Co-authored-by: Smilencer <[email protected]> Co-authored-by: you06 <[email protected]> Co-authored-by: Hu# <[email protected]> Co-authored-by: Connor <[email protected]> Co-authored-by: zyguan <[email protected]> fix case typo in comment. (#778) fix goroutine leak (#784) fix TestRURuntimeStatsCleanUp (#787) Fix wrong resource group name for some requests (#788) resolver: support verifying primary for check_txn_status (#777) resolver: handle pessimistic locks in BatchResolveLocks (#794) resolved ts (#793) ResolveLocks for unistore (#807)
Close #795
after tikv/pd#6413 merged, We can replace resolved-ts's current implementation in client-go