feat(portal-data): instance start/stop/restart

This commit is contained in:
geek 2017-06-09 15:30:48 -05:00 committed by Judit Greskovits
parent 5220139fdb
commit 376136f8dd
3 changed files with 162 additions and 23 deletions

View File

@ -14,7 +14,7 @@ const bootstrap = function () {
const data = new Data(); const data = new Data();
data.connect(() => { data.connect(() => {
data.createDatacenter({ region: 'us-sw', name: 'us-sw' }, (err, datacenter) => { data.createDatacenter({ region: 'us-sw-1', name: 'us-sw-1' }, (err, datacenter) => {
ifError(err); ifError(err);
data.createUser({ firstName: 'Nikola', lastName: 'Tesla', email: 'nikola@tesla.com', login: 'nikola' }, (err, user) => { data.createUser({ firstName: 'Nikola', lastName: 'Tesla', email: 'nikola@tesla.com', login: 'nikola' }, (err, user) => {

View File

@ -0,0 +1,24 @@
consul:
image: autopilotpattern/consul:0.7.2-r0.8
restart: always
dns:
- 127.0.0.1
labels:
- triton.cns.services=consul
ports:
- "8500:8500"
environment:
- CONSUL=consul.svc.30f62ec2-24a2-6f8e-8fad-d46b04c8a0b9.us-sw-1.cns.joyent.com
command: >
/usr/local/bin/containerpilot
/bin/consul agent -server
-config-dir=/etc/consul
-log-level=err
-ui-dir /ui
nats:
image: autopilotpattern/nats:0.9.6-r1.0.0
restart: always
environment:
- CONSUL=consul.svc.30f62ec2-24a2-6f8e-8fad-d46b04c8a0b9.us-sw-1.cns.joyent.com
- NATS_USER=ruser
- NATS_PASSWORD=H4HelAN

View File

@ -768,34 +768,16 @@ module.exports = class Data extends EventEmitter {
} }
_instancesFilter (instanceIds) { _instancesFilter (instanceIds) {
return ({ name, machineId, status }) => { return (query) => {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
const query = { query.ids = instanceIds;
id: this._db.or(instanceIds)
};
if (name) { this.getInstances(query, (err, instances) => {
query.name = name;
}
if (machineId) {
query.machine_id = machineId;
}
if (status) {
query.status = status;
}
this._db.instances.query(query, (err, instances) => {
if (err) { if (err) {
return reject(err); return reject(err);
} }
if (!instances || !instances.length) { resolve(instances);
return resolve([]);
}
resolve(instances.map(Transform.fromInstance));
}); });
}); });
}; };
@ -1004,6 +986,38 @@ module.exports = class Data extends EventEmitter {
}); });
} }
getInstances ({ ids, name, machineId, status }, cb) {
const query = {};
if (ids) {
query.id = this._db.or(ids);
}
if (name) {
query.name = name;
}
if (machineId) {
query.machine_id = machineId;
}
if (status) {
query.status = status;
}
this._db.instances.query(query, (err, instances) => {
if (err) {
return cb(err);
}
if (!instances || !instances.length) {
return cb(null, []);
}
cb(null, instances.map(Transform.fromInstance));
});
}
updateInstance ({ id, status }, cb) { updateInstance ({ id, status }, cb) {
this._db.instances.update(id, { status }, (err, instance) => { this._db.instances.update(id, { status }, (err, instance) => {
if (err) { if (err) {
@ -1014,6 +1028,107 @@ module.exports = class Data extends EventEmitter {
}); });
} }
stopInstances ({ ids }, cb) {
this._db.instances.get(ids, (err, instances) => {
if (err) {
return cb(err);
}
if (!instances || !instances.length) {
return cb();
}
VAsync.forEachParallel({
func: (instance, next) => {
const container = this._docker.getContainer(instance.machine_id);
container.stop((err) => {
if (err) {
return next(err);
}
this.updateInstance({ id: instance.id, status: 'STOPPED' }, next);
});
},
inputs: instances
}, (err, results) => {
if (err) {
return cb(err);
}
this.getInstances({ ids }, cb);
});
});
}
startInstances ({ ids }, cb) {
this._db.instances.get(ids, (err, instances) => {
if (err) {
return cb(err);
}
if (!instances || !instances.length) {
return cb();
}
VAsync.forEachParallel({
func: (instance, next) => {
const container = this._docker.getContainer(instance.machine_id);
container.start((err) => {
if (err) {
return next(err);
}
this.updateInstance({ id: instance.id, status: 'RUNNING' }, next);
});
},
inputs: instances
}, (err, results) => {
if (err) {
return cb(err);
}
this.getInstances({ ids }, cb);
});
});
}
restartInstances ({ ids }, cb) {
this._db.instances.get(ids, (err, instances) => {
if (err) {
return cb(err);
}
if (!instances || !instances.length) {
return cb();
}
VAsync.forEachParallel({
func: (instance, next) => {
this.updateInstance({ id: instance.id, status: 'RESTARTING' }, () => {
const container = this._docker.getContainer(instance.machine_id);
container.restart((err) => {
if (err) {
return next(err);
}
this.updateInstance({ id: instance.id, status: 'RUNNING' }, next);
});
});
},
inputs: instances
}, (err, results) => {
if (err) {
return cb(err);
}
this.getInstances({ ids }, cb);
});
});
}
// packages // packages