network performance testing

Author: sionsmith

stable/network-performance-testing/README.md

@@ -0,0 +1 @@
+deploy a distributed load testing framework that uses multiple containers to create traffic for a simple REST-based API

stable/network-performance-testing/docker/Dockerfile

@@ -0,0 +1,16 @@
+FROM python:3.9.12-slim-bullseye
+
+# Add the external tasks directory into /tasks
+ADD locust-tasks /locust-tasks
+
+# Install the required dependencies via pip
+RUN pip install -r /locust-tasks/requirements.txt
+
+# Expose the required Locust ports
+EXPOSE 5557 5558 8089
+
+# Set script to be executable
+RUN chmod 755 /locust-tasks/run.sh
+
+# Start Locust using LOCUS_OPTS environment variable
+ENTRYPOINT ["/locust-tasks/run.sh"]

stable/network-performance-testing/docker/build-inside.sh

@@ -0,0 +1,3 @@
+#!/bin/bash
+eval $(minikube docker-env)
+docker build -t locust-tasks .

stable/network-performance-testing/docker/locust-tasks/requirements.txt

@@ -0,0 +1,31 @@
+Brotli==1.0.9
+certifi==2021.10.8
+chardet==4.0.0
+charset-normalizer==2.0.12
+click==8.1.2
+ConfigArgParse==1.5.3
+Flask==2.1.1
+Flask-BasicAuth==0.2.0
+Flask-Cors==3.0.10
+gevent==21.12.0
+geventhttpclient==1.5.3
+greenlet==1.1.2
+idna==3.3
+importlib-metadata==4.11.3
+itsdangerous==2.1.2
+Jinja2==3.0.3
+locust==2.8.6
+MarkupSafe==2.1.1
+msgpack==1.0.3
+msgpack-python==0.5.6
+psutil==5.9.0
+pyzmq==22.3.0
+requests==2.27.1
+roundrobin==0.0.2
+six==1.16.0
+typing_extensions==4.1.1
+urllib3==1.26.9
+Werkzeug==2.1.1
+zipp==3.8.0
+zope.event==4.5.0
+zope.interface==5.4.0

stable/network-performance-testing/docker/locust-tasks/run.sh

@@ -0,0 +1,15 @@
+#!/bin/bash
+
+LOCUST="/usr/local/bin/locust"
+LOCUS_OPTS="-f /locust-tasks/tasks.py --host=$TARGET_HOST"
+LOCUST_MODE=${LOCUST_MODE:-standalone}
+
+if [[ "$LOCUST_MODE" = "master" ]]; then
+    LOCUS_OPTS="$LOCUS_OPTS --master"
+elif [[ "$LOCUST_MODE" = "worker" ]]; then
+    LOCUS_OPTS="$LOCUS_OPTS --worker --master-host=$LOCUST_MASTER"
+fi
+
+echo "$LOCUST $LOCUS_OPTS"
+
+$LOCUST $LOCUS_OPTS

stable/network-performance-testing/docker/locust-tasks/tasks.py

@@ -0,0 +1,27 @@
+import uuid
+
+from datetime import datetime
+from locust import FastHttpUser, TaskSet, task
+
+
+# [START locust_test_task]
+
+class MetricsTaskSet(TaskSet):
+    _deviceid = None
+
+    def on_start(self):
+        self._deviceid = str(uuid.uuid4())
+
+    @task(1)
+    def login(self):
+        self.client.post(
+            '/login', {"deviceid": self._deviceid})
+
+    @task(999)
+    def post_metrics(self):
+        self.client.post(
+            "/metrics", {"deviceid": self._deviceid, "timestamp": datetime.now()})
+
+
+class MetricsLocust(FastHttpUser):
+    tasks = {MetricsTaskSet}

stable/network-performance-testing/kustomization.yaml

@@ -0,0 +1,7 @@
+apiVersion: kustomize.config.k8s.io/v1beta1
+kind: Kustomization
+namespace: sandbox
+resources:
+- namespace.yaml
+- ../../base/cfk-components/confluent-no-auth-tls
+- ../../base/cfk-components/confluent-no-auth-tls/schmea-registry

stable/network-performance-testing/namespace.yaml

@@ -0,0 +1,4 @@
+apiVersion: v1
+kind: Namespace
+metadata:
+  name: sandbox