Add reindex operation (#92)

Add new challenge with reindex operation to http_logs track
in order to verify reindex performance before and after resilient
reindex implementation.

Relates elastic/elasticsearch#42612

http_logs/challenges/default.json

@@ -312,4 +312,65 @@
           "clients": 1
         }
       ]
+    },
+    {
+      "name": "append-no-conflicts-index-reindex-only",
+      "description": "Indexes the whole document corpus using Elasticsearch default settings. We only adjust the number of replicas as we benchmark a single node cluster and Rally will only start the benchmark if the cluster turns green. Document ids are unique so all index operations are append only. After indexing, same data are reindexed.",
+      "schedule": [
+        {
+          "operation": "delete-index"
+        },
+        {
+          "operation": {
+            "operation-type": "create-index",
+            "settings": {{index_settings | default({}) | tojson}}
+          }
+        },
+        {
+          "name": "check-cluster-health",
+          "operation": {
+            "operation-type": "cluster-health",
+            "index": "logs-*",
+            "request-params": {
+              "wait_for_status": "{{cluster_health | default('green')}}",
+              "wait_for_no_relocating_shards": "true"
+            }
+          }
+        },
+        {
+          "operation": "index-append",
+          "warmup-time-period": 240,
+          "clients": {{bulk_indexing_clients | default(8)}}
+        },
+        {
+          "name": "refresh-after-index",
+          "operation": "refresh",
+          "clients": 1
+        },
+        {
+          "operation": "force-merge",
+          "clients": 1
+        },
+        {
+          "name": "refresh-after-force-merge",
+          "operation": "refresh",
+          "clients": 1
+        },
+        {
+          "name": "reindex",
+          "operation": {
+            "operation-type": "reindex",
+            "body": {
+              "source": {
+                "index": "logs-*"
+              },
+              "dest": {
+                "index": "reindexed-logs"
+              }
+            },
+            "request_timeout": 7200
+          },
+          "clients": 1
+        }
+      ]
     }

http_logs/track.json

@@ -32,6 +32,10 @@
     {
       "name": "logs-241998",
       "body": "index.json"
+    },
+    {
+      "name": "reindexed-logs",
+      "body": "index.json"
     }
   ],
   "corpora": [

http_logs/track.py

@@ -0,0 +1,6 @@
+def reindex(es, params):
+  result = es.reindex(body=params.get("body"), request_timeout=params.get("request_timeout"))
+  return result["total"], "docs"
+
+def register(registry):
+  registry.register_runner("reindex", reindex)