@@ -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
@@ -161,7 +161,7 @@ perf_test() {
161161 done
162162 } > " $perf_test_job_file "
163163
164- kubectl " $NAMESPACE " apply -f " $perf_test_job_file "
164+ kubectl $NAMESPACE apply -f " $perf_test_job_file "
165165 popd
166166}
167167
@@ -196,14 +196,14 @@ stream_perf_test() {
196196 done
197197 } > " $perf_test_job_file "
198198
199- kubectl " $NAMESPACE " apply -f " $perf_test_job_file "
199+ kubectl $NAMESPACE apply -f " $perf_test_job_file "
200200 popd
201201}
202202
203203manage () {
204204 get_instance_details " $@ "
205205
206- TLS=" $( kubectl " $NAMESPACE " get service " $ service" -o jsonpath=' {.spec.ports[?(@.name=="management-tls")]}' ) "
206+ TLS=" $( kubectl $NAMESPACE get service ${ service} -o jsonpath=' {.spec.ports[?(@.name=="management-tls")]}' ) "
207207 if [[ -n " $TLS " ]]; then
208208 MGMT_PORT=15671
209209 MGMT_URL=" https://localhost:$MGMT_PORT /"
@@ -223,11 +223,11 @@ manage() {
223223 sleep 2
224224 $OPEN " $MGMT_URL "
225225 ) &
226- kubectl " $ NAMESPACE" port-forward " service/${service} " $MGMT_PORT
226+ kubectl ${ NAMESPACE} port-forward " service/${service} " $MGMT_PORT
227227}
228228
229229list_rabbitmq_clusters () {
230- kubectl get " $ NAMESPACE" rabbitmqclusters
230+ kubectl get ${ NAMESPACE} rabbitmqclusters
231231}
232232
233233create () {
@@ -295,48 +295,48 @@ create() {
295295 ;;
296296 esac
297297 done
298- kubectl " $ NAMESPACE" apply -f " $rabbitmq_manifest_file "
298+ kubectl ${ NAMESPACE} apply -f " $rabbitmq_manifest_file "
299299}
300300
301301delete () {
302302 for cluster in " $@ " ; do
303- kubectl " $ NAMESPACE" delete rabbitmqcluster " ${cluster} "
303+ kubectl ${ NAMESPACE} delete rabbitmqcluster " ${cluster} "
304304 done
305305}
306306
307307observe () {
308- kubectl " $ NAMESPACE" exec -it " ${1} -server-${2} " -c rabbitmq -- rabbitmq-diagnostics observer
308+ kubectl ${ NAMESPACE} exec -it " ${1} -server-${2} " -c rabbitmq -- rabbitmq-diagnostics observer
309309}
310310
311311get () {
312- kubectl get " $ NAMESPACE" pods,cm,sts,svc,secrets,rs -l " app.kubernetes.io/name=$1 "
312+ kubectl get ${ NAMESPACE} pods,cm,sts,svc,secrets,rs -l " app.kubernetes.io/name=$1 "
313313}
314314
315315debug () {
316- for node in $( kubectl " $ NAMESPACE" get pods -l " app.kubernetes.io/name=${1} " -ocustom-columns=name:.metadata.name --no-headers) ; do
316+ for node in $( kubectl ${ NAMESPACE} get pods -l " app.kubernetes.io/name=${1} " -ocustom-columns=name:.metadata.name --no-headers) ; do
317317 echo -n " ${node} : "
318- kubectl " $ NAMESPACE" exec " ${node} " -c rabbitmq -- rabbitmqctl set_log_level debug
318+ kubectl ${ NAMESPACE} exec " ${node} " -c rabbitmq -- rabbitmqctl set_log_level debug
319319 done
320320}
321321
322322tail () {
323- kubectl tail " $ NAMESPACE" --svc " ${1} "
323+ kubectl tail ${ NAMESPACE} --svc " ${1} "
324324}
325325
326326enable_all_feature_flags () {
327- kubectl " $ NAMESPACE" exec " ${1} -server-0" -c rabbitmq -- rabbitmqctl enable_feature_flag all
327+ kubectl ${ NAMESPACE} exec " ${1} -server-0" -c rabbitmq -- rabbitmqctl enable_feature_flag all
328328}
329329
330330pause-reconciliation () {
331- kubectl " $ NAMESPACE" label rabbitmqclusters " ${1} " rabbitmq.com/pauseReconciliation=true
331+ kubectl ${ NAMESPACE} label rabbitmqclusters " ${1} " rabbitmq.com/pauseReconciliation=true
332332}
333333
334334resume-reconciliation () {
335- kubectl " $ NAMESPACE" label rabbitmqclusters " ${1} " rabbitmq.com/pauseReconciliation-
335+ kubectl ${ NAMESPACE} label rabbitmqclusters " ${1} " rabbitmq.com/pauseReconciliation-
336336}
337337
338338list-pause-reconciliation-instances () {
339- kubectl get " $ NAMESPACE" rabbitmqclusters -l rabbitmq.com/pauseReconciliation=true --show-labels
339+ kubectl get ${ NAMESPACE} rabbitmqclusters -l rabbitmq.com/pauseReconciliation=true --show-labels
340340}
341341
342342secrets () {
@@ -346,7 +346,7 @@ secrets() {
346346}
347347
348348install_cluster_operator () {
349- kubectl " $ NAMESPACE" apply -f https://github.com/rabbitmq/cluster-operator/releases/latest/download/cluster-operator.yml
349+ kubectl ${ NAMESPACE} apply -f https://github.com/rabbitmq/cluster-operator/releases/latest/download/cluster-operator.yml
350350}
351351
352352main () {
0 commit comments