Adding basic load test.

.gitignore

@@ -10,4 +10,7 @@ build
 *.ipr
 *.iws
 build-idea/
-out/
+out/
+
+venv/
+__pycache__/

load-test/load-test.py

@@ -0,0 +1,24 @@
+import json
+from locust import HttpUser, between, task
+
+class OpenSearchUBIClient(HttpUser):
+    wait_time = between(1, 2)
+
+    @task
+    def event_task(self):
+        headers = {
+            "Content-Type": "application/json"
+        }
+        data = {
+            "type": "instant-search",
+            "keywords": "khgkj",
+            "timestamp": "1705596607509",
+            "url": "file:///C:/jason/_dev/search/OpenSearch/src/search-collector/demo/order.html",
+            "ref": "",
+            "lang": "en-US",
+            "session": "npckcy4",
+            "channel": "demo-channel",
+            "query": ""
+        }
+
+        self.client.post("/_plugins/ubi/mystore", headers=headers, json=data)

load-test/requirements.txt

@@ -0,0 +1 @@
+locust==2.23.1

load-test/run.sh

@@ -0,0 +1,17 @@
+#!/bin/bash -e
+
+# Delete the store if it exists.
+curl -X DELETE http://localhost:9200/_plugins/ubi/mystore
+
+# Create the store
+curl -X PUT http://localhost:9200/_plugins/ubi/mystore
+
+# Insert events
+locust -f load-test.py --headless -u 1 -r 1 --run-time 10s --host http://localhost:9200
+
+# Let events index.
+sleep 2
+
+# Get count of indexed events.
+EVENTS=`curl -s http://localhost:9200/.mystore_events/_count | jq .count`
+echo "Found $EVENTS indexed"