add missing files (got from percona/percona-orchestrator:3.2.6-13)

Author: chernomor

conf/orc-topology.cnf

@@ -0,0 +1,3 @@
+[client]
+user=orchestrator
+password=

docker/Dockerfile

@@ -40,4 +40,7 @@ COPY --from=build /etc/orchestrator.conf.json /etc/orchestrator.conf.json
 
 WORKDIR /usr/local/orchestrator
 ADD docker/entrypoint.sh /entrypoint.sh
+RUN mkdir -p /etc/orchestrator/
+ADD conf/orc-topology.cnf /etc/orchestrator/orc-topology.cnf
+ADD docker/add_mysql_nodes.sh /usr/bin/add_mysql_nodes.sh
 CMD /entrypoint.sh

docker/add_mysql_nodes.sh

@@ -0,0 +1,98 @@
+#!/bin/bash
+
+set -e
+
+ORC_HOST=127.0.0.1:3000
+
+log() {
+	local level=$1
+	local message=$2
+	local now=$(date +%Y-%m-%dT%H:%M:%S%z)
+
+	echo "${now} [${level}] ${message}"
+}
+
+wait_for_leader() {
+	local retry=0
+	local leader=""
+
+	log WARNING "Waiting for leader. Will fail after 60 attempts"
+
+	until [[ ${leader} != "" ]]; do
+		if [ ${retry} -gt 60 ]; then
+			exit 1
+		fi
+
+		local leader=$(curl "${ORC_HOST}/api/raft-leader" 2>/dev/null)
+
+		retry=$((retry + 1))
+		sleep 1
+	done
+}
+
+am_i_leader() {
+	local http_code=$(curl -w httpcode=%{http_code} "${ORC_HOST}/api/leader-check" 2>/dev/null | sed -e 's/.*\httpcode=//')
+
+	if [ ${http_code} -ne 200 ]; then
+		return 1
+	fi
+
+	log INFO "I am the leader"
+	return 0
+}
+
+discover() {
+	local host=$1
+	local port=$2
+
+	HOSTNAME=$(curl -s "${ORC_HOST}/api/instance/${host}/${port}" | jq '.InstanceAlias' | tr -d 'null')
+	if [ -n "$HOSTNAME" ]; then
+		log INFO "The MySQL node ${host} is already discovered by orchestrator. Skipping..."
+		return 0
+	fi
+
+	for i in {1..5}; do
+		R_CODE=$(curl -s "${ORC_HOST}/api/discover/${host}/${port}" | jq '.Code' | tr -d '"')
+		if [ "$R_CODE" == 'ERROR' ]; then
+			log ERROR "MySQL node ${host} can't be discovered"
+			sleep 1
+			continue
+		else
+			log INFO "MySQL node ${host} is discovered"
+			break
+		fi
+	done
+}
+
+main() {
+	log INFO "Starting to discover MySQL nodes."
+
+	# Wait for the leader election
+	wait_for_leader
+
+	log INFO "Orchestrator cluster selected a leader."
+
+	local retry=0
+	# Exit if not leader
+	while ! am_i_leader; do
+		if [ ${retry} -gt 30 ]; then
+			log INFO "I am not the leader. Exiting..."
+			exit 0
+		fi
+
+		retry=$((retry + 1))
+		sleep 1
+	done
+
+	# Discover
+	while read mysql_host; do
+		if [ -z "$mysql_host" ]; then
+			log INFO "Could not find PEERS..."
+			exit 0
+		fi
+
+		discover "${mysql_host}" 3306
+	done
+}
+
+main