-
Notifications
You must be signed in to change notification settings - Fork 25.7k
TransportGetBasicStatusAction runs on local #137567
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
TransportGetBasicStatusAction runs on local #137567
Conversation
|
Pinging @elastic/es-distributed-coordination (Team:Distributed Coordination) |
|
Hi @burqen, I've created a changelog YAML for you. |
It only relies on cluster state. Also, replace GetBasicStatusAction with inline instance of ActionType.
We need to register a request handler for TransportGetBasicStatusAction and make it possible for requests to be read from transport layer in order to support old versions sending GetBasicStatusRequest to us.
ca34860 to
1c6eda4
Compare
DaveCTurner
left a comment
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 (optional comment)
|
|
||
| private static GetBasicStatusResponse getBasicStatus() { | ||
| return safeGet(clusterAdmin().execute(GetBasicStatusAction.INSTANCE, new GetBasicStatusRequest(TEST_REQUEST_TIMEOUT))); | ||
| return safeGet(clusterAdmin().execute(TransportGetBasicStatusAction.TYPE, new GetBasicStatusRequest(TEST_REQUEST_TIMEOUT))); |
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.
This doesn't need to get the specialized cluster admin client:
| return safeGet(clusterAdmin().execute(TransportGetBasicStatusAction.TYPE, new GetBasicStatusRequest(TEST_REQUEST_TIMEOUT))); | |
| return safeGet(client().execute(TransportGetBasicStatusAction.TYPE, new GetBasicStatusRequest(TEST_REQUEST_TIMEOUT))); |
(not introduced in this PR, in fact it was my mistake in #109121, but may as well clean it up here now)
|
|
||
| private static PostStartBasicResponse startBasic(boolean acknowledged) { | ||
| return safeGet( | ||
| clusterAdmin().execute( |
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.
Similarly here
* TransportGetBasicStatusAction runs on local It only relies on cluster state. Also, replace GetBasicStatusAction with inline instance of ActionType. * Handle BwC in TransportGetBasicStatusAction We need to register a request handler for TransportGetBasicStatusAction and make it possible for requests to be read from transport layer in order to support old versions sending GetBasicStatusRequest to us. * Update docs/changelog/137567.yaml * Use client() instead of clusterAdmin() in test
* TransportGetBasicStatusAction runs on local It only relies on cluster state. Also, replace GetBasicStatusAction with inline instance of ActionType. * Handle BwC in TransportGetBasicStatusAction We need to register a request handler for TransportGetBasicStatusAction and make it possible for requests to be read from transport layer in order to support old versions sending GetBasicStatusRequest to us. * Update docs/changelog/137567.yaml * Use client() instead of clusterAdmin() in test
It only relies on cluster state. Also, replace GetBasicStatusAction with inline instance of ActionType.
Relates to #101805