@@ -122,8 +122,8 @@ version() {
122122
123123get_instance_details () {
124124 instance=${1}
125- username=$( kubectl get ${ NAMESPACE} secret " ${instance} -default-user" -o jsonpath=" {.data.username}" | base64 --decode)
126- password=$( kubectl get ${ NAMESPACE} secret " ${instance} -default-user" -o jsonpath=" {.data.password}" | base64 --decode)
125+ username=$( kubectl get " $ NAMESPACE" secret " ${instance} -default-user" -o jsonpath=" {.data.username}" | base64 --decode)
126+ password=$( kubectl get " $ NAMESPACE" secret " ${instance} -default-user" -o jsonpath=" {.data.password}" | base64 --decode)
127127 service=" $instance "
128128}
129129
@@ -132,31 +132,31 @@ perf_test() {
132132 shift 1
133133 perftestopts=$*
134134
135- kubectl ${ NAMESPACE} run perf-test \
135+ kubectl " $ NAMESPACE" run perf-test \
136136 --expose=true \
137137 --port=8080 \
138138 --labels=" app=perf-test,run=perf-test" \
139139 --image=pivotalrabbitmq/perf-test \
140140 -- --uri " amqp://${username} :${password} @${service} " \
141- --metrics-prometheus ${ perftestopts}
141+ --metrics-prometheus " $ perftestopts"
142142}
143143
144144stream_perf_test () {
145145 get_instance_details " $@ "
146146 shift 1
147147 streamperftestopts=$*
148148
149- kubectl ${ NAMESPACE} run stream-perf-test \
149+ kubectl " $ NAMESPACE" run stream-perf-test \
150150 --labels=" app=stream-perf-test,run=stream-perf-test" \
151151 --image=pivotalrabbitmq/stream-perf-test \
152152 -- --uris " rabbitmq-stream://${username} :${password} @${service} " \
153- ${ streamperftestopts}
153+ " $ streamperftestopts"
154154}
155155
156156manage () {
157157 get_instance_details " $@ "
158158
159- TLS=" $( kubectl $NAMESPACE get service ${ service} -o jsonpath=' {.spec.ports[?(@.name=="management-tls")]}' ) "
159+ TLS=" $( kubectl " $NAMESPACE " get service " $ service" -o jsonpath=' {.spec.ports[?(@.name=="management-tls")]}' ) "
160160 if [[ -n " $TLS " ]]; then
161161 MGMT_PORT=15671
162162 MGMT_URL=" https://localhost:$MGMT_PORT /"
@@ -176,11 +176,11 @@ manage() {
176176 sleep 2
177177 $OPEN " $MGMT_URL "
178178 ) &
179- kubectl ${ NAMESPACE} port-forward " service/${service} " $MGMT_PORT
179+ kubectl " $ NAMESPACE" port-forward " service/${service} " $MGMT_PORT
180180}
181181
182182list_rabbitmq_clusters () {
183- kubectl get ${ NAMESPACE} rabbitmqclusters
183+ kubectl get " $ NAMESPACE" rabbitmqclusters
184184}
185185
186186create () {
@@ -248,48 +248,48 @@ create() {
248248 ;;
249249 esac
250250 done
251- kubectl ${ NAMESPACE} apply -f " $rabbitmq_manifest_file "
251+ kubectl " $ NAMESPACE" apply -f " $rabbitmq_manifest_file "
252252}
253253
254254delete () {
255255 for cluster in " $@ " ; do
256- kubectl ${ NAMESPACE} delete rabbitmqcluster " ${cluster} "
256+ kubectl " $ NAMESPACE" delete rabbitmqcluster " ${cluster} "
257257 done
258258}
259259
260260observe () {
261- kubectl ${ NAMESPACE} exec -it " ${1} -server-${2} " -c rabbitmq -- rabbitmq-diagnostics observer
261+ kubectl " $ NAMESPACE" exec -it " ${1} -server-${2} " -c rabbitmq -- rabbitmq-diagnostics observer
262262}
263263
264264get () {
265- kubectl get ${ NAMESPACE} pods,cm,sts,svc,secrets,rs -l " app.kubernetes.io/name=$1 "
265+ kubectl get " $ NAMESPACE" pods,cm,sts,svc,secrets,rs -l " app.kubernetes.io/name=$1 "
266266}
267267
268268debug () {
269- for node in $( kubectl ${ NAMESPACE} get pods -l " app.kubernetes.io/name=${1} " -ocustom-columns=name:.metadata.name --no-headers) ; do
269+ for node in $( kubectl " $ NAMESPACE" get pods -l " app.kubernetes.io/name=${1} " -ocustom-columns=name:.metadata.name --no-headers) ; do
270270 echo -n " ${node} : "
271- kubectl ${ NAMESPACE} exec " ${node} " -c rabbitmq -- rabbitmqctl set_log_level debug
271+ kubectl " $ NAMESPACE" exec " ${node} " -c rabbitmq -- rabbitmqctl set_log_level debug
272272 done
273273}
274274
275275tail () {
276- kubectl tail ${ NAMESPACE} --svc " ${1} "
276+ kubectl tail " $ NAMESPACE" --svc " ${1} "
277277}
278278
279279enable_all_feature_flags () {
280- kubectl ${ NAMESPACE} exec " ${1} -server-0" -c rabbitmq -- rabbitmqctl enable_feature_flag all
280+ kubectl " $ NAMESPACE" exec " ${1} -server-0" -c rabbitmq -- rabbitmqctl enable_feature_flag all
281281}
282282
283283pause-reconciliation () {
284- kubectl ${ NAMESPACE} label rabbitmqclusters " ${1} " rabbitmq.com/pauseReconciliation=true
284+ kubectl " $ NAMESPACE" label rabbitmqclusters " ${1} " rabbitmq.com/pauseReconciliation=true
285285}
286286
287287resume-reconciliation () {
288- kubectl ${ NAMESPACE} label rabbitmqclusters " ${1} " rabbitmq.com/pauseReconciliation-
288+ kubectl " $ NAMESPACE" label rabbitmqclusters " ${1} " rabbitmq.com/pauseReconciliation-
289289}
290290
291291list-pause-reconciliation-instances () {
292- kubectl get ${ NAMESPACE} rabbitmqclusters -l rabbitmq.com/pauseReconciliation=true --show-labels
292+ kubectl get " $ NAMESPACE" rabbitmqclusters -l rabbitmq.com/pauseReconciliation=true --show-labels
293293}
294294
295295secrets () {
@@ -299,7 +299,7 @@ secrets() {
299299}
300300
301301install_cluster_operator () {
302- kubectl ${ NAMESPACE} apply -f https://github.com/rabbitmq/cluster-operator/releases/latest/download/cluster-operator.yml
302+ kubectl " $ NAMESPACE" apply -f https://github.com/rabbitmq/cluster-operator/releases/latest/download/cluster-operator.yml
303303}
304304
305305main () {
0 commit comments