75 lines
2.0 KiB
Bash
75 lines
2.0 KiB
Bash
kubectl_apply() {
|
|
VIA=${1}
|
|
FILE=${2}
|
|
ssh_cmd "${VIA}" "cat ${FILE} | kubectl apply -f -"
|
|
}
|
|
|
|
kubectl_cmd() {
|
|
VIA=${1}
|
|
|
|
shift
|
|
|
|
ssh_cmd "${VIA}" kubectl "${@}"
|
|
}
|
|
|
|
kubectl_wait_for_pod() {
|
|
VIA=${1}
|
|
NAMESPACE=${2}
|
|
POD_NAME=${3}
|
|
SEC=${4:-600}
|
|
log Waiting "${SEC}" seconds for termination of pod "${POD_NAME}"
|
|
|
|
POD_PHASE_JSONPATH='{.status.phase}'
|
|
|
|
end=$(($(date +%s) + SEC))
|
|
while true; do
|
|
POD_PHASE=$(kubectl_cmd "${VIA}" --request-timeout 10s --namespace "${NAMESPACE}" get -o jsonpath="${POD_PHASE_JSONPATH}" pod "${POD_NAME}")
|
|
if [[ ${POD_PHASE} = "Succeeded" ]]; then
|
|
log Pod "${POD_NAME}" succeeded.
|
|
break
|
|
elif [[ $POD_PHASE = "Failed" ]]; then
|
|
log Pod "${POD_NAME}" failed.
|
|
kubectl_cmd "${VIA}" --request-timeout 10s --namespace "${NAMESPACE}" get -o yaml pod "${POD_NAME}" 1>&2
|
|
exit 1
|
|
else
|
|
now=$(date +%s)
|
|
if [[ $now -gt $end ]]; then
|
|
log Pod did not terminate before timeout.
|
|
kubectl_cmd "${VIA}" --request-timeout 10s --namespace "${NAMESPACE}" get -o yaml pod "${POD_NAME}" 1>&2
|
|
exit 1
|
|
fi
|
|
sleep 1
|
|
fi
|
|
done
|
|
}
|
|
|
|
kubectl_wait_for_node_ready() {
|
|
set +x
|
|
|
|
VIA=${1}
|
|
NODE_NAME=${2}
|
|
SEC=${3:-300}
|
|
|
|
log Waiting "${SEC}" seconds for "${NODE_NAME}" to be ready.
|
|
|
|
NODE_READY_JSONPATH='{.status.conditions[?(@.type=="Ready")].status}'
|
|
|
|
end=$(($(date +%s) + SEC))
|
|
while true; do
|
|
if (kubectl_cmd "${VIA}" --request-timeout 10s get nodes "${NODE_NAME}" -o jsonpath="${NODE_READY_JSONPATH}" | grep True) ; then
|
|
log Node "${NODE_NAME}" is ready.
|
|
break
|
|
else
|
|
now=$(date +%s)
|
|
if [ "${now}" -gt "${end}" ]; then
|
|
log Node "${NODE_NAME}" was not ready before timeout.
|
|
fail
|
|
fi
|
|
echo -n .
|
|
sleep 15
|
|
fi
|
|
done
|
|
|
|
set -x
|
|
}
|