Skip to content
Snippets Groups Projects
Commit 626275e9 authored by Nikolay Stanchev's avatar Nikolay Stanchev
Browse files

Updates pipeline script to create the network topology before starting the event loop

parent c1ed3e8f
No related branches found
No related tags found
No related merge requests found
#!/bin/bash #!/bin/bash
CLMC_IP="172.40.231.51"
sfc="fms-sfc" sfc="fms-sfc"
sfci="fms-sfc-1" sfci="fms-sfc-1"
service_function="fms-storage" service_function="fms-storage"
...@@ -13,6 +15,10 @@ query_period=30 ...@@ -13,6 +15,10 @@ query_period=30
ues=("ue20" "ue22" "ue23" "ue24") ues=("ue20" "ue22" "ue23" "ue24")
endpoints=("fms-storage-endpoint" "fms-storage-second-endpoint") endpoints=("fms-storage-endpoint" "fms-storage-second-endpoint")
echo "Building network subgraph..."
response=$(curl -s -X POST http://${CLMC_IP}/clmc-service/graph/network)
echo ${response}
while true while true
do do
echo "Building temporal graph..." echo "Building temporal graph..."
...@@ -33,7 +39,7 @@ do ...@@ -33,7 +39,7 @@ do
--argjson to ${end}\ --argjson to ${end}\
'{from: $from, to: $to, service_function_chain: $sfc, service_function_chain_instance: $sfci, service_functions: {($sf): {measurement_name: $measurement, response_time_field: $response_time, request_size_field: $request_size, response_size_field: $response_size}}}' ) '{from: $from, to: $to, service_function_chain: $sfc, service_function_chain_instance: $sfci, service_functions: {($sf): {measurement_name: $measurement, response_time_field: $response_time, request_size_field: $request_size, response_size_field: $response_size}}}' )
echo "Sending build request to CLMC" echo "Sending build request to CLMC"
response=$(curl -s -X POST -d "${JSON_STRING}" http://172.40.231.51/clmc-service/graph/temporal) response=$(curl -s -X POST -d "${JSON_STRING}" http://${CLMC_IP}/clmc-service/graph/temporal)
timestamp=$(echo ${response} | jq -r '.graph.time_range.to') timestamp=$(echo ${response} | jq -r '.graph.time_range.to')
graph_uuid=$(echo ${response} | jq -r '.graph.uuid') graph_uuid=$(echo ${response} | jq -r '.graph.uuid')
echo "Received request uuid ${graph_uuid}" echo "Received request uuid ${graph_uuid}"
...@@ -43,7 +49,7 @@ do ...@@ -43,7 +49,7 @@ do
for ue in ${ues[@]}; do for ue in ${ues[@]}; do
echo "Querying for round-trip time..." echo "Querying for round-trip time..."
response=$(curl -s -X GET "http://172.40.231.51/clmc-service/graph/temporal/${graph_uuid}/round-trip-time?startpoint=${ue}&endpoint=${endpoint}") response=$(curl -s -X GET "http://${CLMC_IP}/clmc-service/graph/temporal/${graph_uuid}/round-trip-time?startpoint=${ue}&endpoint=${endpoint}")
global_tags=$(echo ${response} | jq -r '.global_tags | to_entries | map("\(.key)=\(.value|tostring)") | join(",")') global_tags=$(echo ${response} | jq -r '.global_tags | to_entries | map("\(.key)=\(.value|tostring)") | join(",")')
echo "Global tags: ${global_tags}" echo "Global tags: ${global_tags}"
...@@ -62,14 +68,14 @@ do ...@@ -62,14 +68,14 @@ do
measurement_line="${rtt_measurement},${global_tags},${local_tags} round_trip_time=${rtt},service_delay=${service_delay},network_delay=${network_delay} ${timestamp}" measurement_line="${rtt_measurement},${global_tags},${local_tags} round_trip_time=${rtt},service_delay=${service_delay},network_delay=${network_delay} ${timestamp}"
echo "Measurement line: ${measurement_line}" echo "Measurement line: ${measurement_line}"
response=$(curl -si -XPOST "http://172.40.231.51/influxdb/write?db=${sfc}" --data-binary "${measurement_line}") response=$(curl -si -XPOST "http://${CLMC_IP}/influxdb/write?db=${sfc}" --data-binary "${measurement_line}")
echo "InfluxDB response: ${response}" echo "InfluxDB response: ${response}"
done done
done done
echo "Deleting temporal graph..." echo "Deleting temporal graph..."
response=$(curl -s -X DELETE "http://172.40.231.51/clmc-service/graph/temporal/${graph_uuid}") response=$(curl -s -X DELETE "http://${CLMC_IP}/clmc-service/graph/temporal/${graph_uuid}")
echo ${response} echo ${response}
echo "Sleeping ${query_period} seconds" echo "Sleeping ${query_period} seconds"
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment