Plug the new PG combinator into monitor

src/cli.cpp

@@ -129,6 +129,8 @@ static const char* help_text =
     "    --block_size 128k             Put pool only on OSDs with this data block size\n"
     "    --bitmap_granularity 4k       Put pool only on OSDs with this logical sector size\n"
     "    --immediate_commit none       Put pool only on OSDs with this or larger immediate_commit (none < small < all)\n"
+    "    --level_placement <rules>     Use additional failure domain rules (example: \"dc=112233\")\n"
+    "    --raw_placement <rules>       Specify raw PG generation rules (see documentation for details)\n"
     "    --primary_affinity_tags tags  Prefer to put primary copies on OSDs with all specified tags\n"
     "    --scrub_interval <time>       Enable regular scrubbing for this pool. Format: number + unit s/m/h/d/M/y\n"
     "    --used_for_fs <name>          Mark pool as used for VitastorFS with metadata in image <name>\n"
@@ -145,6 +147,7 @@ static const char* help_text =
     "    [-s|--pg_size <number>] [--pg_minsize <number>] [-n|--pg_count <count>]\n"
     "    [--failure_domain <level>] [--root_node <node>] [--osd_tags <tags>] [--used_for_fs <name>]\n"
     "    [--max_osd_combinations <number>] [--primary_affinity_tags <tags>] [--scrub_interval <time>]\n"
+    "    [--level_placement <rules>] [--raw_placement <rules>]\n"
     "  Non-modifiable parameters (changing them WILL lead to data loss):\n"
     "    [--block_size <size>] [--bitmap_granularity <size>]\n"
     "    [--immediate_commit <all|small|none>] [--pg_stripe_size <size>]\n"

src/cli_pool_cfg.cpp

@@ -82,9 +82,38 @@ std::string validate_pool_config(json11::Json::object & new_cfg, json11::Json ol
             value = value.uint64_value();
         }
         else if (key == "name" || key == "scheme" || key == "immediate_commit" ||
-            key == "failure_domain" || key == "root_node" || key == "scrub_interval" || key == "used_for_fs")
+            key == "failure_domain" || key == "root_node" || key == "scrub_interval" || key == "used_for_fs" ||
+            key == "raw_placement")
         {
-            // OK
+            if (!value.is_string())
+            {
+                return key+" must be a string";
+            }
+        }
+        else if (key == "level_placement")
+        {
+            // level=rule, level=rule, ...
+            if (!value.is_object())
+            {
+                json11::Json::object obj;
+                for (auto & item: explode(",", value.string_value(), true))
+                {
+                    auto pair = explode("=", item, true);
+                    if (pair.size() >= 2)
+                    {
+                        obj[pair[0]] = pair[1];
+                    }
+                }
+                if (obj.size())
+                {
+                    value = obj;
+                }
+                else
+                {
+                    new_cfg.erase(kv_it++);
+                    continue;
+                }
+            }
         }
         else if (key == "osd_tags" || key == "primary_affinity_tags")
         {
@@ -184,6 +213,38 @@ std::string validate_pool_config(json11::Json::object & new_cfg, json11::Json ol
         return "PG size can't be greater than 256";
     }
 
+    // PG rules
+    if (!cfg["level_placement"].is_null())
+    {
+        for (auto & lr: cfg["level_placement"].object_items())
+        {
+            int len = 0;
+            if (lr.second.is_array())
+            {
+                for (auto & lri: lr.second.array_items())
+                {
+                    if (!lri.is_string() && !lri.is_number())
+                    {
+                        return "--level_placement contains an array with non-scalar value: "+lri.dump();
+                    }
+                }
+                len = lr.second.array_items().size();
+            }
+            else if (!lr.second.is_string())
+            {
+                return "--level_placement contains a non-array and non-string value: "+lr.second.dump();
+            }
+            else
+            {
+                len = lr.second.string_value().size();
+            }
+            if (len != pg_size)
+            {
+                return "values in --level_placement should be exactly pg_size ("+std::to_string(pg_size)+") long";
+            }
+        }
+    }
+
     // parity_chunks
     uint64_t parity_chunks = 1;
     if (scheme == POOL_SCHEME_EC)