-
Notifications
You must be signed in to change notification settings - Fork 2.3k
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
feat(cluster): supports inviting nodes to join the cluster in an asynchronous manner #12267
feat(cluster): supports inviting nodes to join the cluster in an asynchronous manner #12267
Conversation
4879e83
to
fe38629
Compare
c0e5d66
to
c9b9662
Compare
invite_node(put, #{bindings := #{node := Node0}, body := Body}) -> | ||
Node = ekka_node:parse_name(binary_to_list(Node0)), | ||
case maps:get(<<"timeout">>, Body, ?DEFAULT_INVITE_TIMEOUT) of | ||
T when not is_integer(T) -> |
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.
Nit: could that be verified with schema?
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.
In theory, it really should. But for the moment, I haven't found a suitable example to check the format of a field request via schema. 😭
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
cfc3065
to
4b3ecff
Compare
e5a7188
to
4c40e75
Compare
"/cluster/invitation", | ||
"/cluster/:node/invite", | ||
"/cluster/:node/invite_async", | ||
"/cluster/:node/force_leave" |
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.
Maybe we should add async option to invite instead of introduce a new api ?
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
could you double check the ticket/issue? it refers to this PR? |
Fixes https://emqx.atlassian.net/browse/EMQX-11690
Release version: v/e5.5.0
Summary
PR Checklist
Please convert it to a draft if any of the following conditions are not met. Reviewers may skip over until all the items are checked:
Added property-based tests for code which performs user input validationchanges/(ce|ee)/(feat|perf|fix|breaking)-<PR-id>.en.md
filesCreated PR to emqx-docs if documentation update is required, or link to a follow-up jira ticketChecklist for CI (.github/workflows) changes
If changed package build workflow, pass this action (manual trigger)changes/
dir for user-facing artifacts update