Change config schema for the classic autoclustering backend

Fixes #987, references #486, #487.

1 files changed, 16 insertions, 8 deletions

diff --git a/priv/schema/rabbitmq.schema b/priv/schema/rabbitmq.schema
index bf9cccbcb8..f6b18de72f 100644
--- a/priv/schema/rabbitmq.schema
+++ b/priv/schema/rabbitmq.schema
@@ -764,20 +764,28 @@ end}.
 %%
 %% {cluster_nodes, {['rabbit@my.host.com'], disc}},
 
-{mapping, "cluster_nodes.disc.$node", "rabbit.cluster_nodes",
+{mapping, "autocluster.classic_config.nodes.$node", "rabbit.cluster_nodes",
     [{datatype, atom}]}.
 
-{mapping, "cluster_nodes.ram.$node", "rabbit.cluster_nodes",
+{mapping, "autocluster.classic_config.nodes.$node", "rabbit.cluster_nodes",
     [{datatype, atom}]}.
 
+{mapping, "autocluster.classic_config.node_type", "rabbit.cluster_nodes", [
+    {datatype, {enum, [disc, disk, ram]}},
+    {default,  disc}
+]}.
+
 {translation, "rabbit.cluster_nodes",
 fun(Conf) ->
-    DiskNodes = [ V || {_, V} <- cuttlefish_variable:filter_by_prefix("cluster_nodes.disc", Conf)],
-    RamNodes  = [ V || {_, V} <- cuttlefish_variable:filter_by_prefix("cluster_nodes.ram", Conf)],
-
-    case {DiskNodes, RamNodes} of
-        {_,  []} -> {DiskNodes, disc};
-        {[],  _} -> {RamNodes, ram}
+    Nodes = [V || {_, V} <- cuttlefish_variable:filter_by_prefix("autocluster.classic_config.nodes", Conf)],
+
+    case Nodes of
+        []    -> cuttlefish:unset();
+        Other ->
+            case cuttlefish:conf_get("autocluster.classic_config.node_type", Conf, disc) of
+                disc -> {Other, disc};
+                ram  -> {Other, ram}
+            end
     end
 end}.