tools/development/bin/dcae-msgs.sh

   1 #!/usr/bin/env bash
   2 # ============LICENSE_START=======================================================
   3 # dcaegen2-collectors-veshv
   4 # ================================================================================
   5 # Copyright (C) 2018 NOKIA
   6 # ================================================================================
   7 # Licensed under the Apache License, Version 2.0 (the "License");
   8 # you may not use this file except in compliance with the License.
   9 # You may obtain a copy of the License at
  10 #
  11 #      http://www.apache.org/licenses/LICENSE-2.0
  12 #
  13 # Unless required by applicable law or agreed to in writing, software
  14 # distributed under the License is distributed on an "AS IS" BASIS,
  15 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16 # See the License for the specific language governing permissions and
  17 # limitations under the License.
  18 # ============LICENSE_END=========================================================
  19
  20 set -euo pipefail
  21
  22 usage() {
  23     echo "Return current amount of consumed messages by dcae-app-simulator on given topic"
  24     echo "Usage: $0 [-h|--help] [-v|--verbose] <topic>"
  25     echo ""
  26     echo "  - topic : kafka topic to retrieve messages from, default `HV_VES_PERF3GPP`"
  27     exit 1
  28 }
  29
  30 optspec=":vh-:" # catch v, h and -
  31 while getopts "$optspec" arg; do
  32     case "${arg}" in
  33         -) # handle longopts
  34             case "${OPTARG}" in
  35                 verbose)
  36                     VERBOSE=True
  37                     ;;
  38                 help)
  39                     usage
  40                     ;;
  41                 *)
  42                     echo "Unknown option --${OPTARG}" >&2
  43                     usage
  44                     ;;
  45              esac
  46              ;;
  47         v)
  48             VERBOSE=True
  49             ;;
  50         h)
  51             usage
  52             ;;
  53         *)
  54             echo "Unknown option -${OPTARG}" >&2
  55             usage
  56             ;;
  57     esac
  58 done
  59 shift $((OPTIND-1))
  60
  61 TOPIC=${1:-HV_VES_PERF3GPP}
  62
  63 DEVELOPMENT_BIN_DIRECTORY=$(realpath $(dirname "$0"))
  64 source ${DEVELOPMENT_BIN_DIRECTORY}/constants.sh
  65
  66 if [ -n "${VERBOSE+x}" ]; then
  67     echo "All messages count currently consumed by dcae app simulator on topic ${TOPIC}: "
  68 fi
  69
  70 curl --request GET ${DCAE_APP_ADDRESS}/messages/${TOPIC}/count
  71 echo