This commit is contained in:
William Mantly 2016-05-25 15:38:58 -04:00
parent 32e70d4be4
commit f503f370b2

View File

@ -5,17 +5,20 @@ var router = express.Router();
var extend = require('node.extend'); var extend = require('node.extend');
var request = require('request'); var request = require('request');
var lxc = require('../lxc'); var lxc = require('../lxc');
var doapi = require('../doapi')();
var timeoutEvents = {}; var timeoutEvents = {};
var label2container = {}; var label2container = {};
var availContainers = []; var availContainers = [];
var usedContainers = []; var usedContainers = [];
var workers = { var workers = {};
clworker0: {
ip: '104.236.77.157', // var workers = {
name: 'clworker0' // clworker0: {
} // ip: '104.236.77.157',
}; // name: 'clworker0'
// }
// };
var getFreeMem = function(ip, callback){ var getFreeMem = function(ip, callback){
@ -26,6 +29,15 @@ var getFreeMem = function(ip, callback){
); );
}; };
var getWorkers = function(){
doapi.dropletsByTag('clworker', function(data){
data = JSON.parse(data);
data.forEach(function(value){
workers[value.name] = makeWokerObj(value);
});
});
};
var lxcTimeout = function(container, time){ var lxcTimeout = function(container, time){
time = time || 900000; // 15 minutes time = time || 900000; // 15 minutes
var keys = Object.keys(timeoutEvents); var keys = Object.keys(timeoutEvents);
@ -62,6 +74,14 @@ var runner = function(req, res, container){
}); });
}; };
var makeWokerObj = function(woker){
worker.networks.forEach(function(value){
worker[value.type+'IP'] = value.ip_address;
});
worker.ip = worker.privateIP;
return worker;
};
var startWorkers = function(clworker, stopPercent){ var startWorkers = function(clworker, stopPercent){
stopPercent = stopPercent || 30; stopPercent = stopPercent || 30;
console.log(clworker) console.log(clworker)