Skip to content

Commit 7d215b2

Browse files
authored
log-collector: refactor get_k8s_info (#1652)
1 parent abb29f9 commit 7d215b2

File tree

1 file changed

+20
-18
lines changed

1 file changed

+20
-18
lines changed

log-collector-script/linux/eks-log-collector.sh

Lines changed: 20 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -433,31 +433,33 @@ get_docker_logs() {
433433
get_k8s_info() {
434434
try "collect kubelet information"
435435

436-
if [[ -n "${KUBECONFIG:-}" ]]; then
437-
command -v kubectl > /dev/null && kubectl get --kubeconfig="${KUBECONFIG}" svc > "${COLLECT_DIR}"/kubelet/svc.log
438-
command -v kubectl > /dev/null && kubectl --kubeconfig="${KUBECONFIG}" config view --output yaml > "${COLLECT_DIR}"/kubelet/kubeconfig.yaml
439-
440-
elif [[ -f /etc/eksctl/kubeconfig.yaml ]]; then
441-
KUBECONFIG="/etc/eksctl/kubeconfig.yaml"
442-
command -v kubectl > /dev/null && kubectl get --kubeconfig="${KUBECONFIG}" svc > "${COLLECT_DIR}"/kubelet/svc.log
443-
command -v kubectl > /dev/null && kubectl --kubeconfig="${KUBECONFIG}" config view --output yaml > "${COLLECT_DIR}"/kubelet/kubeconfig.yaml
444-
445-
elif [[ -f /etc/systemd/system/kubelet.service ]]; then
446-
KUBECONFIG=$(grep kubeconfig /etc/systemd/system/kubelet.service | awk '{print $2}')
447-
command -v kubectl > /dev/null && kubectl get --kubeconfig="${KUBECONFIG}" svc > "${COLLECT_DIR}"/kubelet/svc.log
448-
command -v kubectl > /dev/null && kubectl --kubeconfig="${KUBECONFIG}" config view --output yaml > "${COLLECT_DIR}"/kubelet/kubeconfig.yaml
436+
find_kubeconfig() {
437+
if [[ -n "${KUBECONFIG:-}" ]]; then
438+
echo "${KUBECONFIG}"
439+
elif [[ -f /etc/eksctl/kubeconfig.yaml ]]; then
440+
echo "/etc/eksctl/kubeconfig.yaml"
441+
elif [[ -f /etc/systemd/system/kubelet.service ]]; then
442+
echo $(grep kubeconfig /etc/systemd/system/kubelet.service | awk '{print $2}')
443+
elif [[ -f /var/lib/kubelet/kubeconfig ]]; then
444+
echo "/var/lib/kubelet/kubeconfig"
445+
else
446+
echo ""
447+
fi
448+
}
449449

450-
elif [[ -f /var/lib/kubelet/kubeconfig ]]; then
451-
KUBECONFIG="/var/lib/kubelet/kubeconfig"
452-
command -v kubectl > /dev/null && kubectl get --kubeconfig=${KUBECONFIG} svc > "${COLLECT_DIR}"/kubelet/svc.log
453-
command -v kubectl > /dev/null && kubectl --kubeconfig=${KUBECONFIG} config view --output yaml > "${COLLECT_DIR}"/kubelet/kubeconfig.yaml
450+
KUBECONFIG_PATH=$(find_kubeconfig)
454451

452+
if [[ -n "${KUBECONFIG_PATH}" ]]; then
453+
command -v kubectl > /dev/null && kubectl get --kubeconfig="${KUBECONFIG_PATH}" svc > "${COLLECT_DIR}"/kubelet/svc.log
454+
command -v kubectl > /dev/null && kubectl --kubeconfig="${KUBECONFIG_PATH}" config view --output yaml > "${COLLECT_DIR}"/kubelet/kubeconfig.yaml
455455
else
456456
echo "======== Unable to find KUBECONFIG, IGNORING POD DATA =========" >> "${COLLECT_DIR}"/kubelet/svc.log
457457
fi
458458

459459
# Try to copy the kubeconfig file if kubectl command doesn't exist
460-
[[ (! -f "${COLLECT_DIR}/kubelet/kubeconfig.yaml") && (-n ${KUBECONFIG}) ]] && cp ${KUBECONFIG} "${COLLECT_DIR}"/kubelet/kubeconfig.yaml
460+
if [[ ! -f "${COLLECT_DIR}/kubelet/kubeconfig.yaml" && -n "${KUBECONFIG_PATH}" ]]; then
461+
cp "${KUBECONFIG_PATH}" "${COLLECT_DIR}/kubelet/kubeconfig.yaml"
462+
fi
461463

462464
case "${INIT_TYPE}" in
463465
systemd)

0 commit comments

Comments
 (0)