| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| lib/ | -91.41% | -149/163 | -78.38% | -58/74 | -100% | -15/15 | -91.3% | -147/161 | -|
| lib/consul/ | -80.95% | -34/42 | -71.43% | -10/14 | -100% | -15/15 | -80.95% | -34/42 | -|
| lib/errors/ | -100% | -2/2 | -100% | -0/0 | -100% | -1/1 | -100% | -2/2 | -
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 -106 -107 -108 -109 -110 -111 -112 -113 -114 -115 -116 -117 -118 -119 -120 -121 -122 -123 -124 -125 -126 -127 -128 -129 -130 -131 -132 -133 -134 -135 -136 -137 -138 -139 -140 -141 -142 -143 -144 -145 -146 -147 -148 -149 -150 -151 -152 -153 -154 -155 -156 -157 -158 -159 -160 -161 -162 -163 -164 -165 -166 -167 -168 -169 -170 -171 -172 -173 -174 -175 -176 -177 -178 -179 -180 -181 -182 -183 -184 -185 -186 -187 -188 -189 -190 -191 -192 -193 -194 -195 -196 -197 -198 -199 -200 -201 -202 -203 -204 -205 -206 -207 -208 -209 -210 -211 -212 -213 -214 -215 -216 -217 -218 -219 -220 -221 -222 -223 -224 -225 -226 -227 -228 -229 -230 -231 -232 -233 -234 -235 -236 -237 -238 -239 -240 -241 -242 -243 -244 -245 -246 -247 -248 -249 -250 -251 -252 -253 -254 -255 -256 -257 -258 -259 -260 -261 -262 -263 -264 -265 -266 -267 -268 -269 -270 -271 -272 -273 -274 -275 -276 -277 -278 | - -22× -22× -22× -22× -22× - - - -21× - -21× -21× -21× - -21× - - - -25× -2× - -1× - -1× -1× - - -25× -2× - -1× - -1× -1× - - - - - -5× - -5× - -2× -1× - -1× - - -4× -6× - -6× - - -1× -1× - - - -5× -4× - -1× -1× - - - - - -3× -3× - -2× -2× - - - - - - - - - -2× - - - - - - - - -4× - -4× -4× - - -2× -1× -1× - - -1× - - -2× - -2× -2× -1× - -1× -1× -1× - - - - - - - - - - -2× - - - - -2× -2× - - - - - - - - - - - - - - - - - - - - - - -2× - -2× -1× -1× - -1× -1× - - - - - - - - - - -3× - - - - - - -3× - - - - -3× -3× - - -3× - -3× - - -3× -3× -9× - -2× -2× -1× - -2× - -2× -2× -2× -1× - - - - - -2× - -1× -1× - -1× - -2× -1× - - - - -3× - -3× - - - - - - - - - -3× - -3× -1× - - -3× -3× -1× - -3× -2× - -3× - -3× - - - - - - - - - -5× -5× -1× - -5× - - - - - - -22× - | 'use strict';
-
-const bunyan = require('bunyan');
-const Consul = require('./consul');
-const Docker = require('./docker');
-const Promise = require('bluebird');
-const SkipError = require('./errors/skipError');
-
-class ConTainer2Sul {
- constructor(config) {
- this.config = config;
-
- this.consul = new Consul(config.consul);
- this.docker = new Docker(this);
- this.log = bunyan.createLogger(config.logger);
-
- this._attachEvents();
- }
-
- _attachEvents() {
- this.docker.events.on('start', msg => {
- return this.docker.client.getContainer(msg.id)
- .inspect()
- .then(container => this.registerContainer(container))
- .catch(error => {
- this.log.error(error);
- throw error;
- });
- });
- this.docker.events.on('die', msg => {
- return this.docker.client.getContainer(msg.id)
- .inspect()
- .then(container => this.deregisterService(this.containerServiceName(container)))
- .catch(error => {
- this.log.error(error);
- throw error;
- });
- });
- }
-
- start() {
- return this.docker.start()
- // deregister containers that do not run
- .then(() => this.consul.kv.keys('docker/service-ids/')
- .catch(error => {
- if (error.statusCode && error.statusCode === 404) {
- return [];
- }
- throw error;
- }))
- .then(keys => {
- return Promise.all(keys.map(key => {
- return this.consul.kv.get(key)
- .then(containerId => {
- return this.docker.client.getContainer(containerId)
- .inspect()
- .then(container => {
- Eif (container.State.Status !== 'running') {
- return this.deregisterService(key);
- }
- })
- .catch(error => {
- if (error.statusCode && error.statusCode === 404) {
- return this.deregisterService(key);
- }
- this.log.error(error);
- throw error;
- });
- });
- }));
- })
- // register all containers
- .then(() => this.docker.containers())
- .then(containers => this.registerContainers(containers))
- .catch(error => {
- this.log.error(error);
- throw error;
- });
- }
-
- /**
- *
- * @param {Container[]} containers
- * @returns {Promise.<*>}
- */
- registerContainers(containers) {
- return Promise.all(containers.map(container => this.registerContainer(container)));
- }
-
- /**
- *
- * @param {Container} container
- * @returns {Promise}
- */
- registerContainer(container) {
- let service;
-
- try {
- service = this.container2Service(container);
- }
- catch (e) {
- if (e instanceof SkipError) {
- this.log.info(e.message);
- return Promise.resolve();
- }
-
- return Promise.reject(e);
- }
-
- this.log.info('registering container', service);
-
- return this.registerContainerKv(container)
- .then(() => this.consul.catalog.register(service))
- .then(() => this.consul.kv.set(`docker/service-ids/${this.containerServiceName(container)}`, container.Id))
- .catch(error => {
- this.consul.kv.delete(`services/${this.containerServiceName(container)}`, true);
- this.log.error(error);
- throw error;
- });
- }
-
- /**
- * Registers key/value pairs for the container
- *
- * @param {Container} container
- * @returns {Promise}
- */
- registerContainerKv(container) {
- const
- lbls = this._containerLabels(container),
- promises = [],
- serviceName = this.containerServiceName(container);
-
- Eif (!lbls) {
- return Promise.resolve();
- }
-
- Object.keys(lbls).forEach(label => {
- if (label.startsWith('consul.kv.')) {
- const
- key = label.replace(/^consul\.kv\./, ''),
- val = lbls[label];
-
- promises.push(this.consul.kv.set(`services/${serviceName}/${key}`, val));
- }
- });
-
- return Promise.all(promises);
- }
-
- /**
- * Un-register a service and related information from Consul
- *
- * @param {string} service
- * @returns {Promise}
- */
- deregisterService(service) {
- this.log.info('deregistering container', service);
-
- return this.consul.catalog.deregister({ Node: service })
- .then(() => this.consul.kv.delete(`docker/service-ids/${service}`))
- .then(() => this.consul.kv.delete(`services/${service}`, true))
- .catch(error => {
- this.log.error(error);
- throw error;
- });
- }
-
- /**
- * Given a container, returns a service definition ready to be consumed by Consul catalog/register API endpoint
- *
- * @param container
- * @returns {Object}
- */
- container2Service(container) {
- let service = {
- Node: this.containerServiceName(container),
- Address: this.docker.docker0,
- Service: {
- Service: this.containerServiceName(container)
- }
- };
- let containerIPAddress = container
- .NetworkSettings
- .Networks[Object.keys(container.NetworkSettings.Networks)[0]]
- .IPAddress;
-
- Eif (containerIPAddress !== '') {
- service.Address = containerIPAddress;
- }
-
- const lbls = this._containerLabels(container);
-
- Iif (Object.keys(lbls).length === 0 || lbls['consul.register'] === 'false' || !lbls['consul.register']) {
- throw new SkipError(`Container ${this.containerServiceName(container)} skipped`);
- }
- Eif (lbls) {
- Object.keys(lbls).forEach(label => {
- switch (label) {
- case 'consul.ip':
- service.Address = lbls[label];
- if (service.Address === 'host') {
- service.Address = this.docker.docker0;
- }
- break;
- case 'consul.port':
- try {
- service.Service.Port = parseInt(lbls[label]);
- if (isNaN(service.Service.Port)) {
- delete service.Service.Port;
- }
- }
- catch (e) {
- // do nothing
- }
- break;
- case 'consul.service':
- service.Service.Service = lbls[label];
- break;
- case 'consul.tags':
- service.Service.Tags = lbls[label]
- .split(',')
- .map(tag => tag.trim());
- break;
- }
- });
- }
-
- this.log.debug('service', service);
-
- return service;
- }
-
- /**
- * Returns the service name for the container
- *
- * @param {Container} container
- * @returns {string}
- */
- containerServiceName(container) {
- let name = container.Name;
-
- if (!name && container.Names) {
- name = container.Names[0];
- }
-
- let lbls = container.Labels;
- if (!lbls && container.Config && container.Config.Labels) {
- lbls = container.Config.Labels;
- }
- if (lbls && lbls['consul.name']) {
- name = lbls['consul.name'];
- }
- name = name.replace(/^\//, '');
-
- return name;
- }
-
- /**
- *
- * @param container
- * @returns {Object}
- * @private
- */
- _containerLabels(container) {
- let lbls = container.Labels;
- if (!lbls && container.Config && container.Config.Labels) {
- lbls = container.Config.Labels;
- }
- return lbls;
- }
-
-}
-
-
-
-module.exports = ConTainer2Sul;
- |
| 1 -2 -3 -4 -5 -6 | - - - - - | const axios = require('axios'); -module.exports = axios.create({ - transformResponse: [function transformResponse(data) { - return JSON.parse(data); - }] -}); |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 | - - - -3× - - - -1× - - - -1× - - - -1× | 'use strict';
-
-class Catalog {
- constructor (consul) {
- this.consul = consul;
- }
-
- register (data) {
- return this.consul._put('/v1/catalog/register', data);
- }
-
- deregister (data) {
- return this.consul._put('/v1/catalog/deregister', data);
- }
-}
-
-module.exports = Catalog; |
| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| catalog.js | -100% | -4/4 | -100% | -0/0 | -100% | -3/3 | -100% | -4/4 | -|
| index.js | -75.86% | -22/29 | -75% | -9/12 | -100% | -7/7 | -75.86% | -22/29 | -|
| kv.js | -88.89% | -8/9 | -50% | -1/2 | -100% | -5/5 | -88.89% | -8/9 | -
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 | -1× -1× -1× - - - -6× -6× - -6× -6× - - - -2× -2× -2× - -2× - - - - - - - - - - - - - - - - - - - - - -2× -1× - -2× - - - -1× - - - - - - - - - - - - - -2× -1× - - -2× - - - -1× - - - -1× - - - -1× - - - -1× | 'use strict';
-const axios = require('axios');
-const Catalog = require('./catalog');
-const Kv = require('./kv');
-
-class Consul {
- constructor(config) {
- this.host = config.host;
- this.port = config.port;
-
- this.acl = config.acl;
- this.dc = config.dc || false;
- }
-
- _send(method, uri, body) {
- Eif (this.acl) {
- uri += uri.indexOf('?') > -1 ? '&' : '?';
- uri += `token=${this.acl}`;
- }
- let request = {
- method,
- baseURL: `http://${this.host}:${this.port}`,
- url: `${uri}`,
- transformResponse: [
- (data) => {
- let resp;
- if (!data) {
- return {};
- }
- try {
- resp = JSON.parse(data);
- } catch (error) {
- throw Error(
- `[requestClient] Error parsingJSON data ${error}`
- );
- }
- return resp;
- },
- ],
- };
-
- if (body) {
- request.data = body;
- }
- return axios(request);
- }
-
- _get(uri) {
- return this._send('GET', uri);
- }
-
- /*
- _post (uri, data) {
- if (this.dc) {
- data.Datacenter = this.dc;
- }
-
- return this._send('POST', uri, data);
- }
- */
-
- _put(uri, data) {
- if (this.dc) {
- data.Datacenter = this.dc;
- }
-
- return this._send('PUT', uri, data);
- }
-
- _delete(uri) {
- return this._send('DELETE', uri);
- }
-
- get catalog() {
- return new Catalog(this);
- }
-
- get kv() {
- return new Kv(this);
- }
-}
-
-module.exports = Consul; |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 | - - - -5× - - - -1× - - - -1× - - - -1× - - - -1× - -1× - - - -1× - - - -1× | 'use strict';
-
-class Kv {
- constructor (consul) {
- this.consul = consul;
- }
-
- keys (prefix) {
- return this.consul._get(`/v1/kv/${prefix}?keys`);
- }
-
- set (key, value) {
- return this.consul._put(`/v1/kv/${key}`, value);
- }
-
- get (key) {
- return this.consul._get(`/v1/kv/${key}?raw`);
- }
-
- delete (key, recurse) {
- let url = `/v1/kv/${key}`;
-
- Iif (recurse === true) {
- url += '?recurse';
- }
-
- return this.consul._delete(url);
- }
-}
-
-module.exports = Kv; |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 -106 -107 -108 -109 -110 -111 -112 -113 -114 -115 -116 -117 -118 -119 -120 -121 -122 -123 -124 -125 -126 -127 -128 -129 -130 -131 -132 -133 -134 -135 -136 -137 -138 -139 -140 -141 -142 -143 -144 -145 -146 -147 -148 -149 -150 -151 -152 -153 -154 -155 -156 -157 -158 -159 -160 -161 -162 -163 -164 -165 -166 -167 -168 -169 -170 -171 -172 -173 -174 -175 -176 -177 -178 -179 -180 -181 -182 -183 -184 -185 -186 -187 -188 -189 -190 -191 -192 -193 -194 -195 -196 -197 -198 -199 -200 -201 -202 -203 -204 -205 -206 -207 -208 -209 -210 -211 -212 -213 -214 -215 -216 -217 -218 -219 -220 -221 -222 -223 -224 -225 -226 -227 -228 -229 -230 -231 -232 -233 -234 -235 -236 -237 -238 -239 -240 -241 -242 -243 -244 -245 -246 -247 -248 -249 -250 -251 -252 -253 -254 -255 -256 -257 -258 -259 -260 -261 -262 -263 -264 -265 -266 -267 -268 -269 -270 -271 -272 -273 -274 -275 -276 -277 -278 -279 -280 -281 -282 -283 | - -22× -22× -22× -22× -22× -22× - - - -21× - -21× -21× -21× - -21× - - - -25× -2× - -1× - -1× -1× - - -25× -2× - -1× - -1× -1× - - - - - -5× - -5× - -2× -1× - -1× - - -4× -6× - -6× - - -1× -1× - - - -5× -4× - -1× -1× - - - - -3× -3× - -2× -2× - - - - - - - - - -2× - - - - - - - - -4× - -4× -4× - - -2× -1× -1× - - -1× - - -2× - -2× -2× -1× - -1× -1× -1× - - - - - - - - - - -2× - - - - -2× -2× - - - - - - - - - - - - - - - - - - - - - - -2× - -2× -1× -1× - -1× -1× - - - - - - - - - - -3× - - - - - - - - - -3× - - - - -3× -3× - - -3× - -3× - - -3× -3× -10× - -2× -2× -1× - -2× - -2× -2× -2× -1× - - - - - - -2× - -1× -1× - -1× - -2× -1× - -1× -1× - - - - -3× - -3× - - - - - - - - - -3× - -3× -1× - - -3× -3× -1× - -3× -2× - -3× - -3× - - - - - - - - - -5× -5× -1× - -5× - - - - -22× - | 'use strict';
-
-const bunyan = require('bunyan');
-const Consul = require('./consul');
-const Docker = require('./docker');
-const Promise = require('bluebird');
-const SkipError = require('./errors/skipError');
-const parse = require('./parse-key-pair');
-
-class ContainertoConsul {
- constructor(config) {
- this.config = config;
-
- this.consul = new Consul(config.consul);
- this.docker = new Docker(this);
- this.log = bunyan.createLogger(config.logger);
-
- this._attachEvents();
- }
-
- _attachEvents() {
- this.docker.events.on('start', msg => {
- return this.docker.client.getContainer(msg.id)
- .inspect()
- .then(container => this.registerContainer(container))
- .catch(error => {
- this.log.error(error);
- throw error;
- });
- });
- this.docker.events.on('die', msg => {
- return this.docker.client.getContainer(msg.id)
- .inspect()
- .then(container => this.deregisterService(this.containerServiceName(container)))
- .catch(error => {
- this.log.error(error);
- throw error;
- });
- });
- }
-
- start() {
- return this.docker.start()
- // deregister containers that do not run
- .then(() => this.consul.kv.keys('docker/service-ids/')
- .catch(error => {
- if (error.statusCode && error.statusCode === 404) {
- return [];
- }
- throw error;
- }))
- .then(keys => {
- return Promise.all(keys.map(key => {
- return this.consul.kv.get(key)
- .then(containerId => {
- return this.docker.client.getContainer(containerId)
- .inspect()
- .then(container => {
- Eif (container.State.Status !== 'running') {
- return this.deregisterService(key);
- }
- })
- .catch(error => {
- if (error.statusCode && error.statusCode === 404) {
- return this.deregisterService(key);
- }
- this.log.error(error);
- throw error;
- });
- });
- }));
- })
- .then(() => this.docker.containers())
- .then(containers => this.registerContainers(containers))
- .catch(error => {
- this.log.error(error);
- throw error;
- });
- }
-
- /**
- *
- * @param {Container[]} containers
- * @returns {Promise.<*>}
- */
- registerContainers(containers) {
- return Promise.all(containers.map(container => this.registerContainer(container)));
- }
-
- /**
- *
- * @param {Container} container
- * @returns {Promise}
- */
- registerContainer(container) {
- let service;
-
- try {
- service = this.container2Service(container);
- }
- catch (e) {
- if (e instanceof SkipError) {
- this.log.info(e.message);
- return Promise.resolve();
- }
-
- return Promise.reject(e);
- }
-
- this.log.info('registering container', service);
-
- return this.registerContainerKv(container)
- .then(() => this.consul.catalog.register(service))
- .then(() => this.consul.kv.set(`docker/service-ids/${this.containerServiceName(container)}`, container.Id))
- .catch(error => {
- this.consul.kv.delete(`services/${this.containerServiceName(container)}`, true);
- this.log.error(error);
- throw error;
- });
- }
-
- /**
- * Registers key/value pairs for the container
- *
- * @param {Container} container
- * @returns {Promise}
- */
- registerContainerKv(container) {
- const
- lbls = this._containerLabels(container),
- promises = [],
- serviceName = this.containerServiceName(container);
-
- Eif (!lbls) {
- return Promise.resolve();
- }
-
- Object.keys(lbls).forEach(label => {
- if (label.startsWith('consul.kv.')) {
- const
- key = label.replace(/^consul\.kv\./, ''),
- val = lbls[label];
-
- promises.push(this.consul.kv.set(`services/${serviceName}/${key}`, val));
- }
- });
-
- return Promise.all(promises);
- }
-
- /**
- * Un-register a service and related information from Consul
- *
- * @param {string} service
- * @returns {Promise}
- */
- deregisterService(service) {
- this.log.info('deregistering container', service);
-
- return this.consul.catalog.deregister({ Node: service })
- .then(() => this.consul.kv.delete(`docker/service-ids/${service}`))
- .then(() => this.consul.kv.delete(`services/${service}`, true))
- .catch(error => {
- this.log.error(error);
- throw error;
- });
- }
-
- /**
- * Given a container, returns a service definition ready to be consumed by Consul catalog/register API endpoint
- *
- * @param container
- * @returns {Object}
- */
- container2Service(container) {
- let service = {
- Node: this.containerServiceName(container),
- Address: this.docker.docker0,
- Service: {
- Service: this.containerServiceName(container),
- Meta: {
- redis_version: '4.0'
- }
- }
- };
- let containerIPAddress = container
- .NetworkSettings
- .Networks[Object.keys(container.NetworkSettings.Networks)[0]]
- .IPAddress;
-
- Eif (containerIPAddress !== '') {
- service.Address = containerIPAddress;
- }
-
- const lbls = this._containerLabels(container);
-
- Iif (Object.keys(lbls).length === 0 || lbls['consul.register'] === 'false' || !lbls['consul.register']) {
- throw new SkipError(`Container ${this.containerServiceName(container)} skipped`);
- }
- Eif (lbls) {
- Object.keys(lbls).forEach(label => {
- switch (label) {
- case 'consul.ip':
- service.Address = lbls[label];
- if (service.Address === 'host') {
- service.Address = this.docker.docker0;
- }
- break;
- case 'consul.port':
- try {
- service.Service.Port = parseInt(lbls[label]);
- if (isNaN(service.Service.Port)) {
- delete service.Service.Port;
- }
- }
- catch (e) {
- // do nothing
- this.log.error(e);
- }
- break;
- case 'consul.service':
- service.Service.Service = lbls[label];
- break;
- case 'consul.tags':
- service.Service.Tags = lbls[label]
- .split(',')
- .map(tag => tag.trim());
- break;
- case 'consul.meta':
- service.Service.Meta = parse(lbls[label]);
- break;
- }
- });
- }
-
- this.log.debug('service', service);
-
- return service;
- }
-
- /**
- * Returns the service name for the container
- *
- * @param {Container} container
- * @returns {string}
- */
- containerServiceName(container) {
- let name = container.Name;
-
- if (!name && container.Names) {
- name = container.Names[0];
- }
-
- let lbls = container.Labels;
- if (!lbls && container.Config && container.Config.Labels) {
- lbls = container.Config.Labels;
- }
- if (lbls && lbls['consul.name']) {
- name = lbls['consul.name'];
- }
- name = name.replace(/^\//, '');
-
- return name;
- }
-
- /**
- *
- * @param container
- * @returns {Object}
- * @private
- */
- _containerLabels(container) {
- let lbls = container.Labels;
- if (!lbls && container.Config && container.Config.Labels) {
- lbls = container.Config.Labels;
- }
- return lbls;
- }
-
-}
-
-module.exports = ContainertoConsul;
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 | - -7× -7× -7× -7× - - - -6× - -6× -6× -6× -6× - - - - - -6× -6× - -5× -4× - -4× - -4× -4× - - - -5× -1× -1× - - - - -2× -1× - - -1× -1× - - - - -1× - - - -7× - | 'use strict';
-
-const DockerOde = require('dockerode');
-const DockerOdePromise = require('dockerode-promise');
-const DockerEvents = require('docker-events');
-const Promise = require('bluebird');
-
-class Docker {
- constructor (containertoConsul) {
- this.containertoConsul = containertoConsul;
-
- this.config = containertoConsul.config.docker;
- this.client = new DockerOdePromise(this.config);
- this.docker0 = '172.17.0.1';
- this.events = new DockerEvents({
- docker: new DockerOde(this.config)
- });
- }
-
- start () {
- return new Promise((resolve) => {
- this.events.start();
-
- this.events.on('connect', () => {
- this.containertoConsul.log.info('Connected to docker');
-
- return this.client.listNetworks()
- .then(networks => {
- this.docker0 = networks.filter(net => net.Name === 'bridge')[0].IPAM.Config[0].Gateway;
- resolve();
- });
- });
-
- this.events.on('disconnect', () => {
- this.containertoConsul.log.warn('Disconnected from Docker. Reconnecting');
- return this.start();
- });
- })
- .timeout(this.config.connectTimeout)
- .catch(error => {
- if (error instanceof Promise.TimeoutError) {
- return this.start();
- }
-
- this.containertoConsul.log.error(error);
- return Promise.reject(error);
- });
- }
-
- containers () {
- return this.client.listContainers();
- }
-}
-
-module.exports = Docker;
- |
| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| skipError.js | -100% | -2/2 | -100% | -0/0 | -100% | -1/1 | -100% | -2/2 | -
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 | - - - -1× - - - -1× - | 'use strict';
-
-class SkipError extends Error {
- constructor (msg) {
- super(msg);
- }
-}
-
-module.exports = SkipError;
- |
| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| container-to-consul.js | -93.81% | -106/113 | -86.54% | -45/52 | -100% | -10/10 | -93.75% | -105/112 | -|
| docker.js | -100% | -26/26 | -100% | -2/2 | -100% | -3/3 | -100% | -25/25 | -|
| parse-key-pair.js | -70.83% | -17/24 | -55% | -11/20 | -100% | -2/2 | -70.83% | -17/24 | -|
| typedefs.js | -100% | -0/0 | -100% | -0/0 | -100% | -0/0 | -100% | -0/0 | -
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 | - - - - - - - - - | /**
- @typedef
- {
- Id: String,
- Labels: String[]
-
-
- } Container
-
- **/ |