Reorganize kafka module
[dcaegen2/collectors/hv-ves.git] / tools / development / bin / dcae-reset.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
23 usage() {
24     echo "Resets dcae-app-simulator consumed messages count on given topic"
25     echo "Usage: $0 [-h|--help] [-v|--verbose] <topic>"
26     echo ""
27     echo "  - topic : kafka topic to reset consumer for, default 'HV_VES_PERF3GPP'"
28     exit 1
29 }
30
31 optspec=":vh-:" # catch v, h and -
32 while getopts "$optspec" arg; do
33     case "${arg}" in
34         -) # handle longopts
35             case "${OPTARG}" in
36                 verbose)
37                     VERBOSE=True
38                     ;;
39                 help)
40                     usage
41                     ;;
42                 *)
43                     echo "Unknown option --${OPTARG}" >&2
44                     usage
45                     ;;
46              esac
47              ;;
48         v)
49             VERBOSE=True
50             ;;
51         h)
52             usage
53             ;;
54         *)
55             echo "Unknown option -${OPTARG}" >&2
56             usage
57             ;;
58     esac
59 done
60 shift $((OPTIND-1))
61
62 TOPIC=${1:-HV_VES_PERF3GPP}
63
64 DEVELOPMENT_BIN_DIRECTORY=$(realpath $(dirname "$0"))
65 source ${DEVELOPMENT_BIN_DIRECTORY}/constants.sh
66
67 if [ -n "${VERBOSE+x}" ]; then
68     echo "Requesting DCAE app running on port ${DCAE_APP_PORT} to reset messages count"
69 fi
70
71 curl --request DELETE ${DCAE_APP_ADDRESS}/messages/${TOPIC}
72 echo