vacp2p/10ksim
1
0
Fork 0
mirror of https://github.com/vacp2p/10ksim.git synced 2025-02-22 19:18:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Cycled generator and fixed .sh

Browse Source
This commit is contained in:
Alberto Soutullo 2024-02-05 16:39:23 +01:00
parent 8901d0f96c
commit ef00165e9d
No known key found for this signature in database
GPG Key ID: A7CAC0D8343B0387
4 changed files with 14 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
deployment/gowaku/deployer_go.sh
View File

@ -23,8 +23,7 @@ fi
cp "template.yaml" "deploy.yaml"
# Loop to generate and append instances
for ((i=0; i<num_containers; i++)); do
cat <<EOF >> "deploy.yaml"
cat <<EOF >> "deploy.yaml"
- name: container-$i
image: gowaku:local
env:
@ -52,7 +51,6 @@ for ((i=0; i<num_containers; i++)); do
- -c
- /usr/bin/waku --relay=true --rpc-admin=true --max-connections=250 --rpc-address=0.0.0.0 --rest=true --rest-admin=true --rest-address=0.0.0.0 --discv5-discovery=true --discv5-enr-auto-update=True --log-level=INFO --rpc-address=0.0.0.0 --metrics-server=True --metrics-server-address=0.0.0.0 --discv5-bootstrap-node=\$ENR1 --discv5-bootstrap-node=\$ENR2 --discv5-bootstrap-node=\$ENR3 --pubsub-topic="/waku/2/kubetopic" --nat=extip:\${IP}
EOF
done
sudo kubectl -n zerotesting delete networkpolicy zerotesting-policy
@ -121,16 +119,10 @@ spec:
selector:
statefulset.kubernetes.io/pod-name: nodes-$i
ports:
EOF
for ((port=8645; port<$((8645 + num_containers)); port++)); do
cat <<EOF >> "deploy.yaml"
- name: port-$port
- name: port-8645
protocol: TCP
port: $port
targetPort : $port
EOF
done
cat <<EOF >> "deploy.yaml"
port: 8645
targetPort : 8645
type: ClusterIP
EOF
done

3
deployment/gowaku/publisher_script/traffic.py
View File

@ -5,6 +5,7 @@ import urllib.parse
import argparse
import aiohttp
import asyncio
from itertools import cycle
async def send_waku_msg(node_address, kbytes, pubsub_topic, content_topic):
@ -70,7 +71,7 @@ if __name__ == "__main__":
print(args)
nodes = pod_generator(args.nodes)
nodes = cycle(pod_generator(args.nodes))
print("Injecting traffic to multiple nodes REST APIs")
print(f"Injecting from node {0} to node {args.nodes}")

20
deployment/nwaku/deployer.sh
View File

@ -23,9 +23,8 @@ fi
cp "template.yaml" "deploy.yaml"
# Loop to generate and append instances
for ((i=0; i<num_containers; i++)); do
cat <<EOF >> "deploy.yaml"
- name: container-$i
cat <<EOF >> "deploy.yaml"
- name: container-0
image: wakuorg/nwaku:wakunode_dst
env:
- name: IP
@ -50,9 +49,8 @@ for ((i=0; i<num_containers; i++)); do
command:
- sh
- -c
- /usr/bin/wakunode --relay=true --rpc-admin=true --max-connections=250 --rpc-address=0.0.0.0 --rest=true --rest-admin=true --rest-private=true --rest-address=0.0.0.0 --discv5-discovery=true --discv5-enr-auto-update=True --log-level=INFO --rpc-address=0.0.0.0 --metrics-server=True --metrics-server-address=0.0.0.0 --discv5-bootstrap-node=\$ENR1 --discv5-bootstrap-node=\$ENR2 --discv5-bootstrap-node=\$ENR3 --nat=extip:\${IP} --pubsub-topic="/waku/2/kubetopic" --ports-shift=$i
- /usr/bin/wakunode --relay=true --rpc-admin=true --max-connections=250 --rpc-address=0.0.0.0 --rest=true --rest-admin=true --rest-private=true --rest-address=0.0.0.0 --discv5-discovery=true --discv5-enr-auto-update=True --log-level=INFO --rpc-address=0.0.0.0 --metrics-server=True --metrics-server-address=0.0.0.0 --discv5-bootstrap-node=\$ENR1 --discv5-bootstrap-node=\$ENR2 --discv5-bootstrap-node=\$ENR3 --nat=extip:\${IP} --pubsub-topic="/waku/2/kubetopic"
EOF
done
sudo kubectl -n zerotesting delete networkpolicy zerotesting-policy
@ -121,16 +119,10 @@ spec:
selector:
statefulset.kubernetes.io/pod-name: nodes-$i
ports:
EOF
for ((port=8645; port<$((8645 + num_containers)); port++)); do
cat <<EOF >> "deploy.yaml"
- name: port-$port
- name: port-8645
protocol: TCP
port: $port
targetPort : $port
EOF
done
cat <<EOF >> "deploy.yaml"
port: 8645
targetPort : 8645
type: ClusterIP
EOF
done

3
deployment/nwaku/publisher_script/traffic.py
View File

@ -5,6 +5,7 @@ import urllib.parse
import argparse
import aiohttp
import asyncio
from itertools import cycle
async def send_waku_msg(node_address, kbytes, pubsub_topic, content_topic):
@ -70,7 +71,7 @@ if __name__ == "__main__":
print(args)
nodes = pod_generator(args.nodes)
nodes = cycle(pod_generator(args.nodes))
print("Injecting traffic to multiple nodes REST APIs")
print(f"Injecting from node {0} to node {args.nodes}")