-
Notifications
You must be signed in to change notification settings - Fork 2.2k
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(ds): make durable sessions handle will messages #12742
Conversation
apps/emqx/integration_test/emqx_persistent_session_ds_SUITE.erl
Outdated
Show resolved
Hide resolved
apps/emqx_eviction_agent/src/proto/emqx_eviction_agent_proto_v3.erl
Outdated
Show resolved
Hide resolved
f7f847d
to
9c227b0
Compare
4a7c513
to
6a05968
Compare
6a05968
to
0d30699
Compare
|
||
-spec set_will_message(emqx_maybe:t(message()), t()) -> t(). | ||
set_will_message(Val, Rec) -> | ||
set_meta(?will_message, Val, Rec). |
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.
Keeping the will message inside the ?meta
table/domain will make things harder for the "session data in DS" feature, because of the lack of transactions there: we'd need to read the metadata and write it back, having the potential of races.
How about we have a table just for that, so that it maps to a topic (in the other PR) that can be safely overwritten without having to read it first?
0d30699
to
0f426e6
Compare
Fixes https://emqx.atlassian.net/browse/EMQX-10431
Release version: v/e5.7
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:
changes/(ce|ee)/(feat|perf|fix|breaking)-<PR-id>.en.md
filesChecklist for CI (.github/workflows) changes
changes/
dir for user-facing artifacts update