diff --git a/scripts/test/pipeline.sh b/scripts/test/pipeline.sh index 6baff4412b4a2402470c476111c0fdc68b38b7b0..dd559ac047ab26241cab9a782699a0c053a88d9f 100644 --- a/scripts/test/pipeline.sh +++ b/scripts/test/pipeline.sh @@ -1,5 +1,7 @@ #!/bin/bash +CLMC_IP="172.40.231.51" + sfc="fms-sfc" sfci="fms-sfc-1" service_function="fms-storage" @@ -13,6 +15,10 @@ query_period=30 ues=("ue20" "ue22" "ue23" "ue24") 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 do echo "Building temporal graph..." @@ -33,7 +39,7 @@ do --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}}}' ) 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') graph_uuid=$(echo ${response} | jq -r '.graph.uuid') echo "Received request uuid ${graph_uuid}" @@ -43,7 +49,7 @@ do for ue in ${ues[@]}; do 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(",")') echo "Global tags: ${global_tags}" @@ -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}" 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}" done done 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 "Sleeping ${query_period} seconds"