Fix naming conflict and redo formatting

This commit is contained in:
Sergey Dudoladov 2018-01-30 12:24:35 +01:00
parent 105bbdb8e4
commit f1bcdd1a8e
1 changed files with 70 additions and 73 deletions

View File

@ -19,73 +19,73 @@ readonly OPERATOR_PORT="8080"
# minikube needs time to create resources, # minikube needs time to create resources,
# so the script retries actions until all the resources become available # so the script retries actions until all the resources become available
function retry(){ function retry(){
# errexit may break "eval $cmd", so we disable it temporarily # errexit may break "eval $retry_cmd", so we disable it temporarily
set +o errexit set +o errexit
local -r cmd="$1" local -r retry_cmd="$1"
local -r retry_msg="$2" local -r retry_msg="$2"
# times out after 1 minute # times out after 1 minute
for i in {1..20}; do for i in {1..20}; do
if eval "$cmd"; then if eval "$retry_cmd"; then
set -o errexit # enable again set -o errexit # enable again
return 0 return 0
fi fi
echo "$retry_msg" echo "$retry_msg"
sleep 3 sleep 3
done done
>2& echo "The command $cmd timed out" >2& echo "The command $retry_cmd timed out"
return 1 return 1
} }
function display_help(){ function display_help(){
echo "Usage: ./run_locally.sh [ -r | --rebuild-operator ] [ -h | --help ]" echo "Usage: ./run_locally.sh [ -r | --rebuild-operator ] [ -h | --help ]"
} }
function clean_up(){ function clean_up(){
echo "==== CLEAN UP PREVIOUS RUN ==== " echo "==== CLEAN UP PREVIOUS RUN ==== "
local status local status
status=$(minikube status --format "{{.MinikubeStatus}}" || true) status=$(minikube status --format "{{.MinikubeStatus}}" || true)
if [[ "$status" = "Running" ]] || [[ "$status" = "Stopped" ]]; then if [[ "$status" = "Running" ]] || [[ "$status" = "Stopped" ]]; then
echo "Delete the existing local cluster so that we can cleanly apply resources from scratch..." echo "Delete the existing local cluster so that we can cleanly apply resources from scratch..."
minikube delete minikube delete
fi fi
if [[ -e "$PATH_TO_LOCAL_OPERATOR_MANIFEST" ]]; then if [[ -e "$PATH_TO_LOCAL_OPERATOR_MANIFEST" ]]; then
rm --verbose "$PATH_TO_LOCAL_OPERATOR_MANIFEST" rm --verbose "$PATH_TO_LOCAL_OPERATOR_MANIFEST"
fi fi
# the kubectl process does the port-forwarding between operator and local ports # the kubectl process does the port-forwarding between operator and local ports
# we restart the process to bind to the same port again (see end of script) # we restart the process to bind to the same port again (see end of script)
if [[ -e "$PATH_TO_PORT_FORWARED_KUBECTL_PID" ]]; then if [[ -e "$PATH_TO_PORT_FORWARED_KUBECTL_PID" ]]; then
local pid local pid
pid=$(cat "$PATH_TO_PORT_FORWARED_KUBECTL_PID") pid=$(cat "$PATH_TO_PORT_FORWARED_KUBECTL_PID")
# the process dies if a minikube stops between two invocations of the script # the process dies if a minikube stops between two invocations of the script
if ps --pid "$pid" > /dev/null 2>&1; then if ps --pid "$pid" > /dev/null 2>&1; then
echo "Kill the kubectl process responsible for port forwarding for minikube so that we can re-use the same ports for forwarding later..." echo "Kill the kubectl process responsible for port forwarding for minikube so that we can re-use the same ports for forwarding later..."
kill "$pid" kill "$pid"
fi fi
rm --verbose /tmp/kubectl-port-forward.pid rm --verbose /tmp/kubectl-port-forward.pid
fi fi
} }
function start_minikube(){ function start_minikube(){
echo "==== START MINIKUBE ==== " echo "==== START MINIKUBE ==== "
echo "May take a few minutes ..." echo "May take a few minutes ..."
minikube start minikube start
kubectl config set-context minikube kubectl config set-context minikube
@ -99,8 +99,8 @@ function build_operator_binary(){
# redirecting stderr greatly reduces non-informative output during normal builds # redirecting stderr greatly reduces non-informative output during normal builds
echo "Build operator binary (stderr redirected to /dev/null)..." echo "Build operator binary (stderr redirected to /dev/null)..."
make tools > /dev/null 2>&1 make tools > /dev/null 2>&1
make deps > /dev/null 2>&1 make deps > /dev/null 2>&1
make local > /dev/null 2>&1 make local > /dev/null 2>&1
} }
@ -109,10 +109,10 @@ function build_operator_binary(){
function deploy_self_built_image() { function deploy_self_built_image() {
echo "==== DEPLOY CUSTOM OPERATOR IMAGE ==== " echo "==== DEPLOY CUSTOM OPERATOR IMAGE ==== "
build_operator_binary build_operator_binary
# the fastest way to run a docker image locally is to reuse the docker from minikube # the fastest way to run a docker image locally is to reuse the docker from minikube
# set docker env vars so that docker can talk to the Docker daemon inside the minikube # set docker env vars so that docker can talk to the Docker daemon inside the minikube
eval $(minikube docker-env) eval $(minikube docker-env)
@ -121,35 +121,35 @@ function deploy_self_built_image() {
local -x TAG local -x TAG
TAG=$(git describe --tags --always --dirty="-dev") TAG=$(git describe --tags --always --dirty="-dev")
readonly TAG readonly TAG
# build the image # build the image
make docker > /dev/null 2>&1 make docker > /dev/null 2>&1
# update the tag in the postgres operator conf # update the tag in the postgres operator conf
# since the image with this tag already exists on the machine, # since the image with this tag already exists on the machine,
# docker should not attempt to fetch it from the registry due to imagePullPolicy # docker should not attempt to fetch it from the registry due to imagePullPolicy
sed --expression "s/\(image\:.*\:\).*$/\1$TAG/" manifests/postgres-operator.yaml > "$PATH_TO_LOCAL_OPERATOR_MANIFEST" sed --expression "s/\(image\:.*\:\).*$/\1$TAG/" manifests/postgres-operator.yaml > "$PATH_TO_LOCAL_OPERATOR_MANIFEST"
retry "kubectl create -f \"$PATH_TO_LOCAL_OPERATOR_MANIFEST\"" "attempt to create $PATH_TO_LOCAL_OPERATOR_MANIFEST resource" retry "kubectl create -f \"$PATH_TO_LOCAL_OPERATOR_MANIFEST\"" "attempt to create $PATH_TO_LOCAL_OPERATOR_MANIFEST resource"
} }
function start_operator(){ function start_operator(){
echo "==== START OPERATOR ==== " echo "==== START OPERATOR ==== "
echo "Certain operations may be retried multiple times..." echo "Certain operations may be retried multiple times..."
# the order of resource initialization is significant # the order of resource initialization is significant
local file local file
for file in "configmap.yaml" "serviceaccount.yaml" for file in "configmap.yaml" "serviceaccount.yaml"
do do
retry "kubectl create -f manifests/\"$file\"" "attempt to create $file resource" retry "kubectl create -f manifests/\"$file\"" "attempt to create $file resource"
done done
if [[ "$should_build_custom_operator" = true ]]; then # set in main() if [[ "$should_build_custom_operator" = true ]]; then # set in main()
deploy_self_built_image deploy_self_built_image
else else
retry "kubectl create -f manifests/postgres-operator.yaml" "attempt to create /postgres-operator.yaml resource" retry "kubectl create -f manifests/postgres-operator.yaml" "attempt to create /postgres-operator.yaml resource"
fi fi
local -r msg="Wait for the postgresql custom resource definition to register..." local -r msg="Wait for the postgresql custom resource definition to register..."
@ -161,76 +161,73 @@ function start_operator(){
function forward_ports(){ function forward_ports(){
echo "==== FORWARD OPERATOR PORT $OPERATOR_PORT TO LOCAL PORT $LOCAL_PORT ====" echo "==== FORWARD OPERATOR PORT $OPERATOR_PORT TO LOCAL PORT $LOCAL_PORT ===="
local operator_pod local operator_pod
operator_pod=$(kubectl get pod -l name=postgres-operator -o jsonpath={.items..metadata.name}) operator_pod=$(kubectl get pod -l name=postgres-operator -o jsonpath={.items..metadata.name})
# runs in the background to keep current terminal responsive # runs in the background to keep current terminal responsive
# stdout redirect removes the info message about forwarded ports; the message sometimes garbles the cli prompt # stdout redirect removes the info message about forwarded ports; the message sometimes garbles the cli prompt
kubectl port-forward "$operator_pod" "$LOCAL_PORT":"$OPERATOR_PORT" &> /dev/null & kubectl port-forward "$operator_pod" "$LOCAL_PORT":"$OPERATOR_PORT" &> /dev/null &
pgrep --newest "kubectl" > "$PATH_TO_PORT_FORWARED_KUBECTL_PID" pgrep --newest "kubectl" > "$PATH_TO_PORT_FORWARED_KUBECTL_PID"
} }
function check_health(){ function check_health(){
echo "==== RUN HEALTH CHECK ==== " echo "==== RUN HEALTH CHECK ==== "
local -r check_cmd="curl --location --silent http://127.0.0.1:$LOCAL_PORT/clusters &> /dev/null" local -r check_cmd="curl --location --silent http://127.0.0.1:$LOCAL_PORT/clusters &> /dev/null"
local -r check_msg="Wait for port forwarding to take effect" local -r check_msg="Wait for port forwarding to take effect"
echo "Command for checking: $check_cmd" echo "Command for checking: $check_cmd"
if retry "$check_cmd" "$check_msg"; then if retry "$check_cmd" "$check_msg"; then
echo "==== SUCCESS: OPERATOR IS RUNNING ==== " echo "==== SUCCESS: OPERATOR IS RUNNING ==== "
echo "To stop it cleanly, run 'minikube delete'" echo "To stop it cleanly, run 'minikube delete'"
else else
>2& echo "==== FAILURE: OPERATOR DID NOT START OR PORT FORWARDING DID NOT WORK" >2& echo "==== FAILURE: OPERATOR DID NOT START OR PORT FORWARDING DID NOT WORK"
>2& echo "This *might* have left the minikube VM image in inconsistent state." exit 1
exit 1
fi fi
} }
function main(){ function main(){
if ! [[ $(basename $PWD) == "postgres-operator" ]]; then if ! [[ $(basename "$PWD") == "postgres-operator" ]]; then
echo "Please execute the script only from the root directory of the Postgres opepator repo." echo "Please execute the script only from the root directory of the Postgres opepator repo."
exit 1 exit 1
fi fi
trap "echo 'If you observe issues with minikube VM not starting/not proceeding, consider deleting the .minikube dir and/or rebooting before re-running the script'" EXIT trap "echo 'If you observe issues with minikube VM not starting/not proceeding, consider deleting the .minikube dir and/or rebooting before re-running the script'" EXIT
local should_build_custom_operator=false # used in start_operator() local should_build_custom_operator=false # used in start_operator()
while true while true
do do
# if the 1st param is unset, use the empty string as a default value # if the 1st param is unset, use the empty string as a default value
case "${1:-}" in case "${1:-}" in
-h | --help) -h | --help)
display_help display_help
exit 0 exit 0
;; ;;
-r | --rebuild-operator) -r | --rebuild-operator)
should_build_custom_operator=true should_build_custom_operator=true
break break
;; ;;
*) break *) break
;; ;;
esac esac
done done
clean_up clean_up
start_minikube start_minikube
start_operator start_operator
forward_ports forward_ports
check_health check_health
exit 0 exit 0
} }
main "$@" main "$@"