UNPKG

2.6 kBJavaScriptView Raw
1var util = require('./util');
2
3/**
4 * Represents an Node
5 * @param {Object} modem docker-modem
6 * @param {String} id Node's ID
7 */
8var Node = function(modem, id) {
9 this.modem = modem;
10 this.id = id;
11};
12
13Node.prototype[require('util').inspect.custom] = function() { return this; };
14
15/**
16 * Query Docker for Node details.
17 *
18 * @param {function} callback
19 */
20Node.prototype.inspect = function(callback) {
21 var self = this;
22
23 var optsf = {
24 path: '/nodes/' + this.id,
25 method: 'GET',
26 statusCodes: {
27 200: true,
28 404: 'no such node',
29 500: 'server error'
30 }
31 };
32
33 if(callback === undefined) {
34 return new this.modem.Promise(function(resolve, reject) {
35 self.modem.dial(optsf, function(err, data) {
36 if (err) {
37 return reject(err);
38 }
39 resolve(data);
40 });
41 });
42 } else {
43 this.modem.dial(optsf, function(err, data) {
44 callback(err, data);
45 });
46 }
47};
48
49
50/**
51 * Update a node.
52 *
53 * @param {object} opts
54 * @param {function} callback
55 */
56Node.prototype.update = function(opts, callback) {
57 var self = this;
58 if (!callback && typeof opts === 'function') {
59 callback = opts;
60 }
61
62 var optsf = {
63 path: '/nodes/' + this.id + '/update?',
64 method: 'POST',
65 statusCodes: {
66 200: true,
67 404: 'no such node',
68 406: 'node is not part of a swarm',
69 500: 'server error'
70 },
71 options: opts
72 };
73
74 if(callback === undefined) {
75 return new this.modem.Promise(function(resolve, reject) {
76 self.modem.dial(optsf, function(err, data) {
77 if (err) {
78 return reject(err);
79 }
80 resolve(data);
81 });
82 });
83 } else {
84 this.modem.dial(optsf, function(err, data) {
85 callback(err, data);
86 });
87 }
88};
89
90
91/**
92 * Remove a Node.
93 * Warning: This method is not documented in the API.
94 *
95 * @param {object} opts
96 * @param {function} callback
97 */
98Node.prototype.remove = function(opts, callback) {
99 var self = this;
100 var args = util.processArgs(opts, callback);
101
102 var optsf = {
103 path: '/nodes/' + this.id + '?',
104 method: 'DELETE',
105 statusCodes: {
106 200: true,
107 404: 'no such node',
108 500: 'server error'
109 },
110 options: args.opts
111 };
112
113 if(args.callback === undefined) {
114 return new this.modem.Promise(function(resolve, reject) {
115 self.modem.dial(optsf, function(err, data) {
116 if (err) {
117 return reject(err);
118 }
119 resolve(data);
120 });
121 });
122 } else {
123 this.modem.dial(optsf, function(err, data) {
124 args.callback(err, data);
125 });
126 }
127};
128
129
130module.exports = Node;