70 lines
1.9 KiB
Plaintext
70 lines
1.9 KiB
Plaintext
|
#!/usr/bin/env bash
|
||
|
|
|
||
|
|
NS="longhorn-system"
|
||
|
|
|
||
|
|
print_usage() {
|
||
|
|
echo "Usage: ${0} [|-h|--help] volume_name longhorn_commands_arguments"
|
||
|
|
echo ""
|
||
|
|
echo "Examples:"
|
||
|
|
echo " ${0} test-vol snapshot ls"
|
||
|
|
echo " ${0} test-vol info"
|
||
|
|
echo ""
|
||
|
|
echo "Note: Must have Longhorn installed in "longhorn-system" namespace and have access to "kubectl" and the namespace"
|
||
|
|
echo ""
|
||
|
|
exit 0
|
||
|
|
}
|
||
|
|
|
||
|
|
check_volume_exist(){
|
||
|
|
VOLUME_NAME=${1}
|
||
|
|
kubectl -n ${NS} get lhv ${VOLUME_NAME} > /dev/null 2>&1
|
||
|
|
if [[ ${?} -ne 0 ]]; then
|
||
|
|
echo "Err: Volume ${VOLUME_NAME} not found"
|
||
|
|
exit 1
|
||
|
|
fi
|
||
|
|
}
|
||
|
|
|
||
|
|
check_engine_state(){
|
||
|
|
VOLUME_NAME=${1}
|
||
|
|
LHE_STATE_FILTER="{.items[?(@.spec.volumeName==\"${VOLUME_NAME}\")].status.currentState}"
|
||
|
|
LHE_STATE=`kubectl -n ${NS} get lhe --output=jsonpath="${LHE_STATE_FILTER}"`
|
||
|
|
|
||
|
|
if [[ ${LHE_STATE} != "running" ]]; then
|
||
|
|
echo "Err: Longhorn engine for volume ${VOLUME_NAME} is not running"
|
||
|
|
exit 1
|
||
|
|
fi
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
exec_command() {
|
||
|
|
VOLUME_NAME=${1}
|
||
|
|
COMMAND_ARGS="${@:2}"
|
||
|
|
|
||
|
|
INSTANCE_MANAGER_NAME_FILTER="{.items[?(@.spec.volumeName==\"${VOLUME_NAME}\")].status.instanceManagerName}"
|
||
|
|
INSTANCE_MANAGER_NAME=`kubectl -n ${NS} get lhe --output=jsonpath="${INSTANCE_MANAGER_NAME_FILTER}"`
|
||
|
|
|
||
|
|
ENGINE_PORT_FILTER="{.items[?(@.spec.volumeName==\"${VOLUME_NAME}\")].status.port}"
|
||
|
|
ENGINE_PORT=`kubectl -n ${NS} get lhe --output=jsonpath="${ENGINE_PORT_FILTER}"`
|
||
|
|
|
||
|
|
kubectl -n ${NS} exec -it ${INSTANCE_MANAGER_NAME} -- bash -c "longhorn --url localhost:${ENGINE_PORT} ${COMMAND_ARGS}"
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
ARG=$1
|
||
|
|
case $ARG in
|
||
|
|
"" | "-h" | "--help")
|
||
|
|
print_usage
|
||
|
|
;;
|
||
|
|
*)
|
||
|
|
VOLUME_NAME=${ARG}
|
||
|
|
shift
|
||
|
|
COMMAND_ARGS="${@}"
|
||
|
|
if [[ ${COMMAND_ARGS} == "" ]]; then
|
||
|
|
COMMAND_ARGS="help"
|
||
|
|
fi
|
||
|
|
check_volume_exist ${VOLUME_NAME}
|
||
|
|
check_engine_state ${VOLUME_NAME}
|
||
|
|
exec_command ${VOLUME_NAME} ${COMMAND_ARGS}
|
||
|
|
;;
|
||
|
|
esac
|