feat: add self node to /cluster

apps/emqx_conf/src/emqx_conf_schema.erl

@@ -800,10 +800,10 @@ fields("log") ->
                 #{
                     mapping => "kernel.error_logger",
                     default => silent,
-                    readOnly => true,
+                    'readOnly' => true,
                     desc => ?DESC("log_error_logger")
-                })
+                }
-        }
+            )}
     ];
 fields("console_handler") ->
     log_handler_common_confs();
@@ -812,8 +812,10 @@ fields("log_file_handler") ->
         {"file",
             sc(
                 file(),
-                #{desc => ?DESC("log_file_handler_file"),
+                #{
-                    validator => fun file_location/1 }
+                    desc => ?DESC("log_file_handler_file"),
+                    validator => fun file_location/1
+                }
             )},
         {"rotation",
             sc(
@@ -1339,5 +1341,6 @@ file_location(File) ->
             nomatch -> Error;
             _ -> ok
         end
-    catch _:_ -> Error
+    catch
+        _:_ -> Error
     end.

apps/emqx_management/src/emqx_mgmt_api_cluster.erl

@@ -43,7 +43,8 @@ schema("/cluster") ->
             responses => #{
                 200 => [
                     {name, ?HOCON(string(), #{desc => "Cluster name"})},
-                    {nodes, ?HOCON(?ARRAY(string()), #{desc => "Node name"})}
+                    {nodes, ?HOCON(?ARRAY(string()), #{desc => "Node name"})},
+                    {self, ?HOCON(string(), #{desc => "Self node name"})}
                 ]
             }
         }
@@ -97,7 +98,8 @@ cluster_info(get, _) ->
     ClusterName = application:get_env(ekka, cluster_name, emqxcl),
     Info = #{
         name => ClusterName,
-        nodes => mria_mnesia:running_nodes()
+        nodes => mria_mnesia:running_nodes(),
+        self => node()
     },
     {200, Info}.