Parcourir la source

chore(rebalance): improve debug logging

Ilya Averyanov il y a 2 ans
Parent
commit
d4b60c5610

+ 1 - 1
apps/emqx_node_rebalance/src/emqx_node_rebalance.app.src

@@ -1,6 +1,6 @@
 {application, emqx_node_rebalance, [
 {application, emqx_node_rebalance, [
     {description, "EMQX Node Rebalance"},
     {description, "EMQX Node Rebalance"},
-    {vsn, "5.0.0"},
+    {vsn, "5.0.1"},
     {registered, [
     {registered, [
         emqx_node_rebalance_sup,
         emqx_node_rebalance_sup,
         emqx_node_rebalance,
         emqx_node_rebalance,

+ 6 - 0
apps/emqx_node_rebalance/src/emqx_node_rebalance.erl

@@ -267,6 +267,9 @@ evict_conns(#{donors := DonorNodes, recipients := RecipientNodes, opts := Opts}
             ConnEvictRate = maps:get(conn_evict_rate, Opts),
             ConnEvictRate = maps:get(conn_evict_rate, Opts),
             NodesToEvict = nodes_to_evict(RecipientAvg, DonorNodeCounts),
             NodesToEvict = nodes_to_evict(RecipientAvg, DonorNodeCounts),
             ?SLOG(warning, #{
             ?SLOG(warning, #{
+                donor_conn_avg => DonorAvg,
+                recipient_conn_avg => RecipientAvg,
+                thresholds => Thresholds,
                 msg => "node_rebalance_evict_conns",
                 msg => "node_rebalance_evict_conns",
                 nodes => NodesToEvict,
                 nodes => NodesToEvict,
                 counts => ConnEvictRate
                 counts => ConnEvictRate
@@ -297,6 +300,9 @@ evict_sessions(#{donors := DonorNodes, recipients := RecipientNodes, opts := Opt
             SessEvictRate = maps:get(sess_evict_rate, Opts),
             SessEvictRate = maps:get(sess_evict_rate, Opts),
             NodesToEvict = nodes_to_evict(RecipientAvg, DonorNodeCounts),
             NodesToEvict = nodes_to_evict(RecipientAvg, DonorNodeCounts),
             ?SLOG(warning, #{
             ?SLOG(warning, #{
+                donor_sess_avg => DonorAvg,
+                recipient_sess_avg => RecipientAvg,
+                thresholds => Thresholds,
                 msg => "node_rebalance_evict_sessions",
                 msg => "node_rebalance_evict_sessions",
                 nodes => NodesToEvict,
                 nodes => NodesToEvict,
                 counts => SessEvictRate
                 counts => SessEvictRate