Add 'Galera DB backup' pipeline
Related: PROD-27547 (PROD:27547)
Change-Id: I2540ec4460ea6c6932a4e758543b8340e0a9d9fd
diff --git a/galera-database-backup-pipeline.groovy b/galera-database-backup-pipeline.groovy
new file mode 100644
index 0000000..a6d0af5
--- /dev/null
+++ b/galera-database-backup-pipeline.groovy
@@ -0,0 +1,61 @@
+def common = new com.mirantis.mk.Common()
+def salt = new com.mirantis.mk.Salt()
+def galera = new com.mirantis.mk.Galera()
+def python = new com.mirantis.mk.Python()
+def pepperEnv = "pepperEnv"
+
+backupNode = "none"
+primaryNodes = []
+syncedNodes = []
+galeraMembers = []
+
+if (common.validInputParam('OVERRIDE_BACKUP_NODE')) {
+ backupNode = OVERRIDE_BACKUP_NODE
+}
+
+timeout(time: 12, unit: 'HOURS') {
+ node() {
+ stage('Setup virtualenv for Pepper') {
+ python.setupPepperVirtualenv(pepperEnv, SALT_MASTER_URL, SALT_MASTER_CREDENTIALS)
+ }
+ if (backupNode.equals("none")) {
+ stage('Locate Primary component') {
+ galeraMembers = salt.getMinions(pepperEnv, "I@galera:master or I@galera:slave")
+ for (member in galeraMembers) { // STEP 1 - Locate all nodes that belong to Primary component
+ try {
+ salt.minionsReachable(pepperEnv, "I@salt:master", member)
+ memberStatus = galera.getWsrepParameters(pepperEnv, member, "wsrep_cluster_status", false)
+ if (memberStatus.get('wsrep_cluster_status').equals("Primary")) {
+ primaryNodes.add(member)
+ common.infoMsg("Adding ${member} as a member of a Primary component.")
+ } else {
+ common.warningMsg("Ignoring ${member} node, because it's not part of a Primary component.")
+ }
+ } catch (Exception e) {
+ common.warningMsg("Minion '${member}' is not reachable or is not possible to determine its status.")
+ }
+ }
+ }
+ stage('Choose backup node') {
+ backupNode = primaryNodes.sort()[0] // STEP 2 - Use node with lowest hostname number (last option if everything previous fails)
+ }
+ } else {
+ stage('Choose backup node') {
+ common.infoMsg("Backup node backup was overriden to ${backupNode}.")
+ }
+ }
+ stage ('Prepare for backup') {
+ salt.enforceState(pepperEnv, 'I@xtrabackup:server', ['linux.system.repo', 'xtrabackup'])
+ salt.enforceState(pepperEnv, 'I@xtrabackup:client', ['linux.system.repo', 'openssh.client'])
+ }
+ stage('Backup') {
+ common.infoMsg("Node ${backupNode} was selected as a backup node.")
+ input: "Please check selected backup node and confirm to run the backup procedure."
+ salt.cmdRun(pepperEnv, backupNode, "su root -c 'salt-call state.sls xtrabackup'")
+ salt.cmdRun(pepperEnv, backupNode, "su root -c '/usr/local/bin/innobackupex-runner.sh -s'")
+ }
+ stage('Clean-up') {
+ salt.cmdRun(pepperEnv, backupNode, "su root -c '/usr/local/bin/innobackupex-runner.sh -c'")
+ }
+ }
+}
\ No newline at end of file