kafka-demo.groovy

/**
 *
 * Run states on K8s
 *
 * Expected parameters:
 *   SALT_MASTER_CREDENTIALS    Credentials used to access Salt API
 *   SALT_URL                   URL usedd to connect to Salt API
 */

common = new com.mirantis.mk.Common()
salt = new com.mirantis.mk.Salt()
orchestrate = new com.mirantis.mk.Orchestrate()
timeout(time: 12, unit: 'HOURS') {
    node {

        // connection objects
        def master

        stage("Connect to Salt master") {
            master = salt.connection(SALT_URL, SALT_MASTER_CREDENTIALS)
        }


        stage("Enforce kubernetes.control") {
            common.infoMsg('Enforcing kubernetes.control on I@kubernetes:master')

            salt.enforceState(
                master,
                'I@kubernetes:master',
                'kubernetes.control'
            )
        }

        stage("setup-components") {
            common.infoMsg('Setting up components')

            salt.cmdRun(
                master,
                'I@kubernetes:master',
                '/bin/bash -c \'find /srv/kubernetes/ -type d | grep -v jobs | while read i; do ls $i/*.yml &>/dev/null && (set -x; hyperkube kubectl apply -f $i || echo Command failed; set +x); done;\'')

        }

    }
}