Преглед на файлове

Merge pull request #13062 from ieQu1/dev/ds-better-naming

fix(sessds): Rename last_alive_update_interval -> heartbeat_interval
ieQu1 преди 1 година
родител
ревизия
5ba71ae6f7

+ 1 - 1
apps/emqx/integration_test/emqx_persistent_session_ds_SUITE.erl

@@ -57,7 +57,7 @@ init_per_testcase(t_session_gc = TestCase, Config) ->
         roles => [core, core, core],
         roles => [core, core, core],
         extra_emqx_conf =>
         extra_emqx_conf =>
             "\n durable_sessions {"
             "\n durable_sessions {"
-            "\n   last_alive_update_interval = 500ms "
+            "\n   heartbeat_interval = 500ms "
             "\n   session_gc_interval = 1s "
             "\n   session_gc_interval = 1s "
             "\n   session_gc_batch_size = 2 "
             "\n   session_gc_batch_size = 2 "
             "\n }"
             "\n }"

+ 2 - 2
apps/emqx/src/emqx_persistent_session_ds.erl

@@ -1146,11 +1146,11 @@ receive_maximum(ConnInfo) ->
 expiry_interval(ConnInfo) ->
 expiry_interval(ConnInfo) ->
     maps:get(expiry_interval, ConnInfo, 0).
     maps:get(expiry_interval, ConnInfo, 0).
 
 
-%% Note: we don't allow overriding `last_alive_update_interval' per
+%% Note: we don't allow overriding `heartbeat_interval' per
 %% zone, since the GC process is responsible for all sessions
 %% zone, since the GC process is responsible for all sessions
 %% regardless of the zone.
 %% regardless of the zone.
 bump_interval() ->
 bump_interval() ->
-    emqx_config:get([durable_sessions, last_alive_update_interval]).
+    emqx_config:get([durable_sessions, heartbeat_interval]).
 
 
 get_config(#{zone := Zone}, Key) ->
 get_config(#{zone := Zone}, Key) ->
     emqx_config:get_zone_conf(Zone, [durable_sessions | Key]).
     emqx_config:get_zone_conf(Zone, [durable_sessions | Key]).

+ 1 - 1
apps/emqx/src/emqx_persistent_session_ds_gc_worker.erl

@@ -134,7 +134,7 @@ start_gc() ->
 
 
 gc_context() ->
 gc_context() ->
     GCInterval = emqx_config:get([durable_sessions, session_gc_interval]),
     GCInterval = emqx_config:get([durable_sessions, session_gc_interval]),
-    BumpInterval = emqx_config:get([durable_sessions, last_alive_update_interval]),
+    BumpInterval = emqx_config:get([durable_sessions, heartbeat_interval]),
     TimeThreshold = max(GCInterval, BumpInterval) * 3,
     TimeThreshold = max(GCInterval, BumpInterval) * 3,
     NowMS = now_ms(),
     NowMS = now_ms(),
     #{
     #{

+ 2 - 2
apps/emqx/src/emqx_schema.erl

@@ -1678,12 +1678,12 @@ fields("durable_sessions") ->
                     desc => ?DESC(session_ds_idle_poll_interval)
                     desc => ?DESC(session_ds_idle_poll_interval)
                 }
                 }
             )},
             )},
-        {"last_alive_update_interval",
+        {"heartbeat_interval",
             sc(
             sc(
                 timeout_duration(),
                 timeout_duration(),
                 #{
                 #{
                     default => <<"5000ms">>,
                     default => <<"5000ms">>,
-                    desc => ?DESC(session_ds_last_alive_update_interval)
+                    desc => ?DESC(session_ds_heartbeat_interval)
                 }
                 }
             )},
             )},
         {"renew_streams_interval",
         {"renew_streams_interval",

+ 1 - 1
apps/emqx/test/emqx_config_SUITE.erl

@@ -471,7 +471,7 @@ zone_global_defaults() ->
                 batch_size => 100,
                 batch_size => 100,
                 force_persistence => false,
                 force_persistence => false,
                 idle_poll_interval => 100,
                 idle_poll_interval => 100,
-                last_alive_update_interval => 5000,
+                heartbeat_interval => 5000,
                 message_retention_period => 86400000,
                 message_retention_period => 86400000,
                 renew_streams_interval => 5000,
                 renew_streams_interval => 5000,
                 session_gc_batch_size => 100,
                 session_gc_batch_size => 100,

+ 1 - 1
apps/emqx/test/emqx_persistent_session_SUITE.erl

@@ -78,7 +78,7 @@ init_per_group(persistence_enabled, Config) ->
             ?EMQX_CONFIG ++
             ?EMQX_CONFIG ++
                 "durable_sessions {\n"
                 "durable_sessions {\n"
                 "  enable = true\n"
                 "  enable = true\n"
-                "  last_alive_update_interval = 100ms\n"
+                "  heartbeat_interval = 100ms\n"
                 "  renew_streams_interval = 100ms\n"
                 "  renew_streams_interval = 100ms\n"
                 "  session_gc_interval = 2s\n"
                 "  session_gc_interval = 2s\n"
                 "}"},
                 "}"},

+ 1 - 1
apps/emqx/test/emqx_takeover_SUITE.erl

@@ -71,7 +71,7 @@ init_per_group(persistence_enabled = Group, Config) ->
             {emqx,
             {emqx,
                 "durable_sessions = {\n"
                 "durable_sessions = {\n"
                 "  enable = true\n"
                 "  enable = true\n"
-                "  last_alive_update_interval = 100ms\n"
+                "  heartbeat_interval = 100ms\n"
                 "  renew_streams_interval = 100ms\n"
                 "  renew_streams_interval = 100ms\n"
                 "  session_gc_interval = 2s\n"
                 "  session_gc_interval = 2s\n"
                 "}\n"}
                 "}\n"}

+ 1 - 1
apps/emqx_management/test/emqx_mgmt_SUITE.erl

@@ -61,7 +61,7 @@ init_per_group(persistence_enabled, Config) ->
             {emqx,
             {emqx,
                 "durable_sessions {\n"
                 "durable_sessions {\n"
                 "  enable = true\n"
                 "  enable = true\n"
-                "  last_alive_update_interval = 100ms\n"
+                "  heartbeat_interval = 100ms\n"
                 "  renew_streams_interval = 100ms\n"
                 "  renew_streams_interval = 100ms\n"
                 "}"},
                 "}"},
             emqx_management
             emqx_management

+ 1 - 0
changes/ce/fix-13062.en.md

@@ -0,0 +1 @@
+Rename configuration parameter `durable_sessions.last_alive_update_interval` to `durable_sessions.heartbeat_interval`.