v2.0.2

Author: apocas

examples/timeout.js

@@ -0,0 +1,20 @@
+var Docker = require('../lib/docker');
+var fs     = require('fs');
+
+var socket = process.env.DOCKER_SOCKET || '/var/run/docker.sock';
+var stats  = fs.statSync(socket);
+
+if (!stats.isSocket()) {
+  throw new Error("Are you sure the docker is running?");
+}
+
+//you may specify a timeout for all operations, allowing to make sure you don't fall into limbo if something happens in docker
+var docker = new Docker({host: 'http://127.0.0.1', port: 2375, timeout: 1});
+
+docker.createContainer({Image: 'ubuntu', Cmd: ['/bin/bash']}, function (err, container) {
+  container.start(function (err, data) {
+    container.top({ps_args: 'aux'}, function(err, data) {
+      console.log(data);
+    });
+  });
+});

package.json

@@ -1,7 +1,7 @@
 {
   "name": "dockerode",
   "description": "Docker.io / Docker remote API implementation.",
-  "version": "2.0.1",
+  "version": "2.0.2",
   "author": "Pedro Dias <petermdias@gmail.com>",
   "maintainers": [
     "apocas <petermdias@gmail.com>"

test/docker.js

@@ -81,6 +81,19 @@ describe("#docker", function() {
     });
   });
 
+  describe("#testTimeout", function() {
+    it("should timeout", function(done) {
+      this.timeout(30000);
+
+      function handler(err, data) {
+        expect(err).to.not.be.null;
+        done();
+      }
+
+      dockert.ping(handler);
+    });
+  });
+
   describe('#pull', function() {
     this.timeout(120000);
 

test/spec_helper.js

@@ -13,10 +13,13 @@ var docker;
 if (!stats.isSocket()) {
   console.log('Trying TCP connection...');
   docker = new Docker({host: process.env.DOCKER_HOST || 'http://127.0.0.1', port: process.env.DOCKER_PORT || 3000});
+  dockert = new Docker({host: process.env.DOCKER_HOST || 'http://127.0.0.1', port: process.env.DOCKER_PORT || 3000, timeout: 1});
 } else {
   docker = new Docker({ socketPath: socket });
+  dockert = new Docker({ socketPath: socket, timeout: 1 });
 }
 
 module.exports = {
-  'docker': docker
+  'docker': docker,
+  'dockert': dockert
 };