yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(sessds): add field to `ds_pubrange` for forward-compat

This commit is contained in:
Andrew Mayorov 2023-11-20 19:56:55 +07:00
parent 7081f1951f
commit ef7cfd0202
No known key found for this signature in database
GPG Key ID: 2837C62ACFBFED5D
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
apps/emqx/src/emqx_persistent_session_ds.hrl
View File

@ -62,7 +62,9 @@
%% the range. %% the range.
%% * For checkpoint range, this is the iterator pointing right past the last %% * For checkpoint range, this is the iterator pointing right past the last
%% message in the range. %% message in the range.
iterator :: emqx_ds:iterator() iterator :: emqx_ds:iterator(),
%% Reserved for future use.
misc = #{} :: map()
}). }).
-type ds_pubrange() :: #ds_pubrange{}. -type ds_pubrange() :: #ds_pubrange{}.
@ -72,7 +74,6 @@
%% creation time %% creation time
created_at :: _Millisecond :: non_neg_integer(), created_at :: _Millisecond :: non_neg_integer(),
expires_at = never :: _Millisecond :: non_neg_integer() | never, expires_at = never :: _Millisecond :: non_neg_integer() | never,
% last_ack = 0 :: emqx_persistent_message_ds_replayer:seqno(),
%% for future usage %% for future usage
props = #{} :: map() props = #{} :: map()
}). }).