mirror of
				https://github.com/k3s-io/kubernetes.git
				synced 2025-11-04 07:49:35 +00:00 
			
		
		
		
	Prior this change, etcd wasn't cleaned up on my machine that lead to orphaned etcd process after the update-swagger-spec.sh failed. This change also adds additional improvements: - don't kill/wait/rm when argument is empty. - use kube::util::trap_add.
		
			
				
	
	
		
			115 lines
		
	
	
		
			4.0 KiB
		
	
	
	
		
			Bash
		
	
	
		
			Executable File
		
	
	
	
	
			
		
		
	
	
			115 lines
		
	
	
		
			4.0 KiB
		
	
	
	
		
			Bash
		
	
	
		
			Executable File
		
	
	
	
	
#!/bin/bash
 | 
						|
 | 
						|
# Copyright 2014 The Kubernetes Authors.
 | 
						|
#
 | 
						|
# Licensed under the Apache License, Version 2.0 (the "License");
 | 
						|
# you may not use this file except in compliance with the License.
 | 
						|
# You may obtain a copy of the License at
 | 
						|
#
 | 
						|
#     http://www.apache.org/licenses/LICENSE-2.0
 | 
						|
#
 | 
						|
# Unless required by applicable law or agreed to in writing, software
 | 
						|
# distributed under the License is distributed on an "AS IS" BASIS,
 | 
						|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 | 
						|
# See the License for the specific language governing permissions and
 | 
						|
# limitations under the License.
 | 
						|
 | 
						|
# A set of helpers for starting/running etcd for tests
 | 
						|
 | 
						|
ETCD_VERSION=${ETCD_VERSION:-3.1.10}
 | 
						|
ETCD_HOST=${ETCD_HOST:-127.0.0.1}
 | 
						|
ETCD_PORT=${ETCD_PORT:-2379}
 | 
						|
 | 
						|
kube::etcd::validate() {
 | 
						|
  # validate if in path
 | 
						|
  which etcd >/dev/null || {
 | 
						|
    kube::log::usage "etcd must be in your PATH"
 | 
						|
    exit 1
 | 
						|
  }
 | 
						|
 | 
						|
  # validate it is not running
 | 
						|
  if pgrep -x etcd >/dev/null 2>&1; then
 | 
						|
    kube::log::usage "etcd appears to already be running on this machine (`pgrep -xl etcd`) (or its a zombie and you need to kill its parent)."
 | 
						|
    kube::log::usage "retry after you resolve this etcd error."
 | 
						|
    exit 1
 | 
						|
  fi
 | 
						|
 | 
						|
  # validate installed version is at least equal to minimum
 | 
						|
  version=$(etcd --version | tail -n +1 | head -n 1 | cut -d " " -f 3)
 | 
						|
  if [[ $(kube::etcd::version $ETCD_VERSION) -gt $(kube::etcd::version $version) ]]; then
 | 
						|
   export PATH=$KUBE_ROOT/third_party/etcd:$PATH
 | 
						|
   hash etcd
 | 
						|
   echo $PATH
 | 
						|
   version=$(etcd --version | head -n 1 | cut -d " " -f 3)
 | 
						|
   if [[ $(kube::etcd::version $ETCD_VERSION) -gt $(kube::etcd::version $version) ]]; then
 | 
						|
    kube::log::usage "etcd version ${ETCD_VERSION} or greater required."
 | 
						|
    kube::log::info "You can use 'hack/install-etcd.sh' to install a copy in third_party/."
 | 
						|
    exit 1
 | 
						|
   fi
 | 
						|
  fi
 | 
						|
}
 | 
						|
 | 
						|
kube::etcd::version() {
 | 
						|
  printf '%s\n' "${@}" | awk -F . '{ printf("%d%03d%03d\n", $1, $2, $3) }'
 | 
						|
}
 | 
						|
 | 
						|
kube::etcd::start() {
 | 
						|
  # validate before running
 | 
						|
  kube::etcd::validate
 | 
						|
 | 
						|
  # Start etcd
 | 
						|
  ETCD_DIR=${ETCD_DIR:-$(mktemp -d 2>/dev/null || mktemp -d -t test-etcd.XXXXXX)}
 | 
						|
  if [[ -d "${ARTIFACTS_DIR:-}" ]]; then
 | 
						|
    ETCD_LOGFILE="${ARTIFACTS_DIR}/etcd.$(uname -n).$(id -un).log.DEBUG.$(date +%Y%m%d-%H%M%S).$$"
 | 
						|
  else
 | 
						|
    ETCD_LOGFILE=/dev/null
 | 
						|
  fi
 | 
						|
  kube::log::info "etcd --advertise-client-urls http://${ETCD_HOST}:${ETCD_PORT} --data-dir ${ETCD_DIR} --listen-client-urls http://${ETCD_HOST}:${ETCD_PORT} --debug > \"${ETCD_LOGFILE}\" 2>/dev/null"
 | 
						|
  etcd --advertise-client-urls http://${ETCD_HOST}:${ETCD_PORT} --data-dir ${ETCD_DIR} --listen-client-urls http://${ETCD_HOST}:${ETCD_PORT} --debug 2> "${ETCD_LOGFILE}" >/dev/null &
 | 
						|
  ETCD_PID=$!
 | 
						|
 | 
						|
  echo "Waiting for etcd to come up."
 | 
						|
  kube::util::wait_for_url "http://${ETCD_HOST}:${ETCD_PORT}/v2/machines" "etcd: " 0.25 80
 | 
						|
  curl -fs -X PUT "http://${ETCD_HOST}:${ETCD_PORT}/v2/keys/_test"
 | 
						|
}
 | 
						|
 | 
						|
kube::etcd::stop() {
 | 
						|
  if [[ -n "${ETCD_PID-}" ]]; then
 | 
						|
    kill "${ETCD_PID}" &>/dev/null || :
 | 
						|
    wait "${ETCD_PID}" &>/dev/null || :
 | 
						|
  fi
 | 
						|
}
 | 
						|
 | 
						|
kube::etcd::clean_etcd_dir() {
 | 
						|
  if [[ -n "${ETCD_DIR-}" ]]; then
 | 
						|
    rm -rf "${ETCD_DIR}"
 | 
						|
  fi
 | 
						|
}
 | 
						|
 | 
						|
kube::etcd::cleanup() {
 | 
						|
  kube::etcd::stop
 | 
						|
  kube::etcd::clean_etcd_dir
 | 
						|
}
 | 
						|
 | 
						|
kube::etcd::install() {
 | 
						|
  (
 | 
						|
    cd "${KUBE_ROOT}/third_party"
 | 
						|
    if [[ $(uname) == "Darwin" ]]; then
 | 
						|
      download_file="etcd-v${ETCD_VERSION}-darwin-amd64.zip"
 | 
						|
      url="https://github.com/coreos/etcd/releases/download/v${ETCD_VERSION}/${download_file}"
 | 
						|
      kube::util::download_file "${url}" "${download_file}"
 | 
						|
      unzip -o "${download_file}"
 | 
						|
      ln -fns "etcd-v${ETCD_VERSION}-darwin-amd64" etcd
 | 
						|
      rm "${download_file}"
 | 
						|
    else
 | 
						|
      url="https://github.com/coreos/etcd/releases/download/v${ETCD_VERSION}/etcd-v${ETCD_VERSION}-linux-amd64.tar.gz"
 | 
						|
      download_file="etcd-v${ETCD_VERSION}-linux-amd64.tar.gz"
 | 
						|
      kube::util::download_file "${url}" "${download_file}"
 | 
						|
      tar xzf "${download_file}"
 | 
						|
      ln -fns "etcd-v${ETCD_VERSION}-linux-amd64" etcd
 | 
						|
    fi
 | 
						|
    kube::log::info "etcd v${ETCD_VERSION} installed. To use:"
 | 
						|
    kube::log::info "export PATH=$(pwd)/etcd:\${PATH}"
 | 
						|
  )
 | 
						|
}
 |