From f503f370b2d0626699b217667533b457242bdc29 Mon Sep 17 00:00:00 2001 From: william Date: Wed, 25 May 2016 15:38:58 -0400 Subject: [PATCH] stuff --- routes/api.js | 32 ++++++++++++++++++++++++++------ 1 file changed, 26 insertions(+), 6 deletions(-) diff --git a/routes/api.js b/routes/api.js index ebf740e..ae78346 100644 --- a/routes/api.js +++ b/routes/api.js @@ -5,17 +5,20 @@ var router = express.Router(); var extend = require('node.extend'); var request = require('request'); var lxc = require('../lxc'); +var doapi = require('../doapi')(); var timeoutEvents = {}; var label2container = {}; var availContainers = []; var usedContainers = []; -var workers = { - clworker0: { - ip: '104.236.77.157', - name: 'clworker0' - } -}; +var workers = {}; + +// var workers = { +// clworker0: { +// ip: '104.236.77.157', +// name: 'clworker0' +// } +// }; 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){ time = time || 900000; // 15 minutes 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){ stopPercent = stopPercent || 30; console.log(clworker)