client: resource manager service discovery#9785
client: resource manager service discovery#9785ti-chi-bot[bot] merged 40 commits intotikv:masterfrom
Conversation
Signed-off-by: disksing <i@disksing.com>
|
Skipping CI for Draft Pull Request. |
Codecov Report❌ Patch coverage is Additional details and impacted files@@ Coverage Diff @@
## master #9785 +/- ##
==========================================
+ Coverage 78.40% 78.53% +0.12%
==========================================
Files 518 520 +2
Lines 69438 69658 +220
==========================================
+ Hits 54441 54703 +262
+ Misses 11045 11004 -41
+ Partials 3952 3951 -1
Flags with carried forward coverage won't be shown. Click here to find out more. 🚀 New features to boost your workflow:
|
Signed-off-by: okjiang <819421878@qq.com>
Signed-off-by: okjiang <819421878@qq.com>
Signed-off-by: okjiang <819421878@qq.com>
Signed-off-by: okjiang <819421878@qq.com>
Signed-off-by: okjiang <819421878@qq.com>
Signed-off-by: okjiang <819421878@qq.com>
Signed-off-by: disksing <i@disksing.com>
Signed-off-by: okjiang <819421878@qq.com>
Signed-off-by: okjiang <819421878@qq.com>
|
/retest |
Signed-off-by: okjiang <819421878@qq.com>
|
/retest |
Signed-off-by: okjiang <819421878@qq.com>
Signed-off-by: okjiang <819421878@qq.com>
Signed-off-by: okjiang <819421878@qq.com>
|
/retest |
| func (r *ResourceManagerDiscovery) resetConn(url string) { | ||
| r.mu.Lock() | ||
| defer r.mu.Unlock() | ||
| if url == "" { |
| r.resetConn(url) | ||
| revision = newRevision | ||
| } | ||
| case <-r.updateServiceURLCh: |
There was a problem hiding this comment.
What is the difference between <-ticker.C and <-r.updateServiceURLCh?
There was a problem hiding this comment.
If the request failed, client will trigger updateServiceURLCh to update url actively.
There was a problem hiding this comment.
The handle code does not exist any difference.
There was a problem hiding this comment.
Then we can reduce the duplicated code?
Signed-off-by: okjiang <819421878@qq.com>
|
/retest |
|
/retest |
| } | ||
|
|
||
| // ScheduleUpateServiceURL schedules an update of the service URL. | ||
| func (r *ResourceManagerDiscovery) ScheduleUpateServiceURL() { |
There was a problem hiding this comment.
| func (r *ResourceManagerDiscovery) ScheduleUpateServiceURL() { | |
| func (r *ResourceManagerDiscovery) ScheduleUpdateServiceURL() { |
Signed-off-by: okjiang <819421878@qq.com>
client/inner_client.go
Outdated
| } | ||
| } | ||
|
|
||
| func shouldScheduleResourceManagerServiceURLUpdate(err error) bool { |
There was a problem hiding this comment.
updated to shouldUpdateRMURL
Signed-off-by: okjiang <819421878@qq.com>
|
/retest |
1 similar comment
|
/retest |
|
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: disksing, niubell, rleungx The full list of commands accepted by this bot can be found here. The pull request process is described here DetailsNeeds approval from an approver in each of these files:
Approvers can indicate their approval by writing |
What problem does this PR solve?
Issue Number: Ref #9737
What is changed and how does it work?
Check List
Tests
Code changes
Side effects
Related changes
pingcap/docs/pingcap/docs-cn:pingcap/tiup:Release note