public/rancher-docs
1
0
Fork 0
mirror of https://github.com/rancher/rancher-docs.git synced 2026-09-26 04:58:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Better leader check

Browse Source
This commit is contained in:
Vincent Fiduccia
2018-07-12 15:03:23 -07:00
parent 06daab11b5
commit 5f750affcd
3 changed files with 28 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files
gulpfile.babel.js
+27 -23
View File
@@ -17,6 +17,7 @@ const fs = require('fs');
const $ = gulpLoadPlugins();
const browserSync = require('browser-sync').create();
const request = require('request');
const isProduction = process.env.NODE_ENV === 'production';
process.on('SIGINT', (err) => {
@@ -29,10 +30,6 @@ process.on('uncaughtException', (err) => {
process.exit(1);
});
console.log('&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&')
console.log(process.env)
console.log('&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&')
// --
gulp.task('dev', ['build-dev'], () => {
gulp.start('init-watch');
@@ -194,26 +191,33 @@ gulp.task('publish:search-index', (cb) => {
env: env
};
request.get({url: 'http://rancher-metadata/2015-07-25/self/service/containers/0', timeout: 2000}, function(err, res, first) {
if ( err ) {
return cb(err);
}
console.log('Waiting');
setTimeout(() => {
console.log('Done');
exec('giddyup leader check', opts, function(err, stdout, stderr) {
console.log('Error:', err);
console.log('Stdout:', stdout);
console.log('Stderr:', stderr);
}).on('close', code => {
if (code === 0) {
console.log('Publishing to algolia', process.env.ALGOLIA_INDEX_NAME);
atomicalgolia(process.env.ALGOLIA_INDEX_NAME, process.env.ALGOLIA_INDEX_FILE, {verbose: true}, (err, result) => {
console.log(result);
cb(err);
});
} else {
console.log('I am not the leader (' + code + ')');
cb(new Error('Not the leader'));
request.get({url: 'http://rancher-metadata/2015-07-25/self/container/name', timeout: 2000}, function(err, res, me) {
if ( err ) {
return cb(err);
}
});
}, 10000);
console.log('First:', first);
console.log('Me:', me);
if ( !first || !me ) {
return cb(new Error('Unable to determine who is the leader (' + first + ', ' + me+ ')'));
}
if ( first !== me ) {
console.log('I am not the leader');
return cb();
}
console.log('Publishing to algolia', process.env.ALGOLIA_INDEX_NAME);
atomicalgolia(process.env.ALGOLIA_INDEX_NAME, process.env.ALGOLIA_INDEX_FILE, {verbose: true}, (err, result) => {
console.log(result);
cb(err);
});
});
});
});