deploy.sh

#!/bin/bash
set -eu

SCRIPT=`realpath -s $0`
SCRIPT_PATH=`dirname $SCRIPT`

TEMPLATE=${SCRIPT_PATH}/dist/ovs-flowmon.yaml.j2
POD_SPEC=${SCRIPT_PATH}/build/ovs-flowmon.yaml
IMAGE=quay.io/amorenoz/ovs-flowmon
OVN_K8S_NAMESPACE="ovn-kubernetes"
OVN_CENTRAL="unknown"
MODE="ovs"
mkdir -p ${SCRIPT_PATH}/build

usage() {
    echo "$0 [OPTIONS] NODE_NAME"
    echo ""
    echo "Deploy the ovs-flowmon to debug the OVS running on a k8s NODE"
    echo ""
    echo "Options"
    echo "  -i IMAGE   Use a different container image"
    echo "  -o         OVN drop-sampling mode"
    echo ""
}

error() {
    echo $@ > %2
    exit 1
}
is_command_fail() {
	set +e
	local cmd=$1
	if ! command -v $cmd &> /dev/null; then
		echo "ERROR - command '$cmd' not found, exiting."
		exit 1
	fi
	set -e
}

KUBECTL=""
get_kubectl_binary() {
	set +e
	KUBECTL=$(which oc 2>/dev/null)
	ret_code="$?"
	if [ $ret_code -eq 0 ]; then
		set -e
		return
	fi

	# Note: "local OC_LOCATION=" will set the return code to 0, always
	# so must keep this in public scope
	KUBECTL=$(which kubectl 2>/dev/null)
	ret_code="$?"
	if [ $ret_code -eq 0 ]; then
		set -e
		return
	fi

	echo "ERROR - could not find oc/kubectl binary, exiting."
	exit 1
}

if [ $# -lt 1 ]; then
    usage
    exit 1
fi

while getopts ":hoi:" opt; do
    case ${opt} in
        h)
            usage
            exit 0
            ;;
        i)
            IMAGE=$OPTARG
            ;;
        o)
            MODE="ovn"
            ;;
    esac
done

shift $(((OPTIND -1)))
NODE=$1

get_kubectl_binary
is_command_fail pip
is_command_fail grep

# Ensure j2 installed
pip freeze | grep j2cli || pip install j2cli[yaml] --user

# j2 may be installed, but the pip user path might not be added to PATH
is_command_fail j2

$KUBECTL get node $NODE &>/dev/null || "kubectl cannot access node $NODE. Ensure the node name is correct and you have access to the cluster (KUBECONFIG)"

if [[ ${MODE} == "ovn" ]]; then
    IFS=" " read -a ovn_db_hosts <<<"$(${KUBECTL} get ep -n ${OVN_K8S_NAMESPACE} ovnkube-db -o=jsonpath='{range .subsets[0].addresses[*]}{.ip}{" "}')"
    if [[ ${#ovn_db_hosts[@]} == 0 ]]; then
        error "Cannot determine ovn endpoint"
    fi
    OVN_CENTRAL=${ovn_db_hosts[0]}
fi

deployment=$(uuidgen | cut -d "-" -f 1)
node=${NODE} \
    image=${IMAGE} \
    ovn_central=${OVN_CENTRAL} \
    mode=${MODE} \
    deployment=${deployment} \
    j2 ${TEMPLATE} -o ${POD_SPEC}

$KUBECTL label nodes --overwrite ${NODE} flowmon=${deployment}

$KUBECTL apply -f ${POD_SPEC}

echo "Waiting for pod to switch to ready condition. This can take a while (timeout 300s) ..."
$KUBECTL wait pod --for=condition=ready --timeout=300s -l app=ovs-flowmon

$KUBECTL exec -it ovs-flowmon-${NODE} -- /root/run