apocas/dockerode apocas/dockerode

  • Stars
    star
    4,339
  • Rank 9,910 (Top 0.2 %)
  • Language
    JavaScript
  • License
    Apache License 2.0
  • Created over 11 years ago
  • Updated 5 months ago
Twitter logo Share LinkedIn logo Share Facebook logo Share
apocas/dockerode
github

apocas

Reviews

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

Repository Details

Docker + Node = Dockerode (Node.js module for Docker's Remote API)

dockerode

Not another Node.js Docker Remote API module.

dockerode objectives:

  • streams - dockerode does NOT break any stream, it passes them to you allowing for some stream voodoo.
  • stream demux - Supports optional stream demultiplexing.
  • entities - containers, images and execs are defined entities and not random static methods.
  • run - dockerode allow you to seamless run commands in a container ala docker run.
  • tests - dockerode really aims to have a good test set, allowing to follow Docker changes easily, quickly and painlessly.
  • feature-rich - There's a real effort in keeping All Docker Remote API features implemented and tested.
  • interfaces - Features callback and promise based interfaces, making everyone happy :)

Ecosystem

Installation

npm install dockerode

Usage

  • Input options are directly passed to Docker. Check Docker API documentation for more details.
  • Return values are unchanged from Docker, official Docker documentation will also apply to them.
  • Check the tests and examples folder for more examples.

Getting started

To use dockerode first you need to instantiate it:

var Docker = require('dockerode');
var docker = new Docker({socketPath: '/var/run/docker.sock'});
var docker1 = new Docker(); //defaults to above if env variables are not used
var docker2 = new Docker({host: 'http://192.168.1.10', port: 3000});
var docker3 = new Docker({protocol:'http', host: '127.0.0.1', port: 3000});
var docker4 = new Docker({host: '127.0.0.1', port: 3000}); //defaults to http

//protocol http vs https is automatically detected
var docker5 = new Docker({
  host: '192.168.1.10',
  port: process.env.DOCKER_PORT || 2375,
  ca: fs.readFileSync('ca.pem'),
  cert: fs.readFileSync('cert.pem'),
  key: fs.readFileSync('key.pem'),
  version: 'v1.25' // required when Docker >= v1.13, https://docs.docker.com/engine/api/version-history/
});

var docker6 = new Docker({
  protocol: 'https', //you can enforce a protocol
  host: '192.168.1.10',
  port: process.env.DOCKER_PORT || 2375,
  ca: fs.readFileSync('ca.pem'),
  cert: fs.readFileSync('cert.pem'),
  key: fs.readFileSync('key.pem')
});

//using a different promise library (default is the native one)
var docker7 = new Docker({
  Promise: require('bluebird')
  //...
});
//...

Manipulating a container:

// create a container entity. does not query API
var container = docker.getContainer('71501a8ab0f8');

// query API for container info
container.inspect(function (err, data) {
  console.log(data);
});

container.start(function (err, data) {
  console.log(data);
});

container.remove(function (err, data) {
  console.log(data);
});

// promises are supported
var auxContainer;
docker.createContainer({
  Image: 'ubuntu',
  AttachStdin: false,
  AttachStdout: true,
  AttachStderr: true,
  Tty: true,
  Cmd: ['/bin/bash', '-c', 'tail -f /var/log/dmesg'],
  OpenStdin: false,
  StdinOnce: false
}).then(function(container) {
  auxContainer = container;
  return auxContainer.start();
}).then(function(data) {
  return auxContainer.resize({
    h: process.stdout.rows,
    w: process.stdout.columns
  });
}).then(function(data) {
  return auxContainer.stop();
}).then(function(data) {
  return auxContainer.remove();
}).then(function(data) {
  console.log('container removed');
}).catch(function(err) {
  console.log(err);
});

You may also specify default options for each container's operations, which will always be used for the specified container and operation.

container.defaultOptions.start.Binds = ["/tmp:/tmp:rw"];

Stopping all containers on a host

docker.listContainers(function (err, containers) {
  containers.forEach(function (containerInfo) {
    docker.getContainer(containerInfo.Id).stop(cb);
  });
});

Building an Image

Context: provides the path to the Dockerfile. Additionaly files that are involved in the build must be explicitly mentioned in src array, since they are sent to a temp env to build. Example: file for COPY command are extracted from that temporary environment.

docker.buildImage('archive.tar', {t: imageName}, function (err, response){
  //...
});

docker.buildImage({
  context: __dirname,
  src: ['Dockerfile', 'file1', 'file2']
}, {t: imageName}, function (err, response) {
  //...
});

buildImage returns a Promise of NodeJS stream. In case you want to find out when the build has finished, you must follow the progress of the build with the modem instance in dockerode:

let dockerode = new Dockerode();
let stream = await dockerode.buildImage(...);
await new Promise((resolve, reject) => {
  dockerode.modem.followProgress(stream, (err, res) => err ? reject(err) : resolve(res));
});
// Build has finished

Creating a container:

docker.createContainer({Image: 'ubuntu', Cmd: ['/bin/bash'], name: 'ubuntu-test'}, function (err, container) {
  container.start(function (err, data) {
    //...
  });
});
//...

Streams goodness:

//tty:true
docker.createContainer({ /*...*/ Tty: true /*...*/ }, function(err, container) {

  /* ... */

  container.attach({stream: true, stdout: true, stderr: true}, function (err, stream) {
    stream.pipe(process.stdout);
  });

  /* ... */
});

//tty:false
docker.createContainer({ /*...*/ Tty: false /*...*/ }, function(err, container) {

  /* ... */

  container.attach({stream: true, stdout: true, stderr: true}, function (err, stream) {
    //dockerode may demultiplex attach streams for you :)
    container.modem.demuxStream(stream, process.stdout, process.stderr);
  });

  /* ... */
});

docker.createImage({fromImage: 'ubuntu'}, function (err, stream) {
  stream.pipe(process.stdout);
});

//...

There is also support for HTTP connection hijacking, which allows for cleaner interactions with commands that work with stdin and stdout separately.

docker.createContainer({Tty: false, /*... other options */}, function(err, container) {
  container.start(function(err) {
    container.exec({Cmd: ['shasum', '-'], AttachStdin: true, AttachStdout: true}, function(err, exec) {
      exec.start({hijack: true, stdin: true}, function(err, stream) {
        // shasum can't finish until after its stdin has been closed, telling it that it has
        // read all the bytes it needs to sum. Without a socket upgrade, there is no way to
        // close the write-side of the stream without also closing the read-side!
        fs.createReadStream('node-v5.1.0.tgz', 'binary').pipe(stream);

        // Fortunately, we have a regular TCP socket now, so when the readstream finishes and closes our
        // stream, it is still open for reading and we will still get our results :-)
        docker.modem.demuxStream(stream, process.stdout, process.stderr);
      });
    });
  });
});

Equivalent of docker run in dockerode:

  • image - container image
  • cmd - command to be executed
  • stream - stream(s) which will be used for execution output.
  • create_options - (optional) Options used for container creation. Refer to the DockerEngine ContainerCreate documentation for the possible values
  • start_options - (optional) Options used for container start. Refer to the DockerEngine ContainerStart documentation for the possible values
  • callback - callback called when execution ends (optional, promise will be returned if not used).
//callback
docker.run('ubuntu', ['bash', '-c', 'uname -a'], process.stdout, function (err, data, container) {
  console.log(data.StatusCode);
});

//promise
docker.run(testImage, ['bash', '-c', 'uname -a'], process.stdout).then(function(data) {
  var output = data[0];
  var container = data[1];
  console.log(output.StatusCode);
  return container.remove();
}).then(function(data) {
  console.log('container removed');
}).catch(function(err) {
  console.log(err);
});

or, if you want to split stdout and stderr (you must to pass Tty:false as an option for this to work)

docker.run('ubuntu', ['bash', '-c', 'uname -a'], [process.stdout, process.stderr], {Tty:false}, function (err, data, container) {
  console.log(data.StatusCode);
});

If you provide a callback, run will return an EventEmitter supporting the following events: container, stream, data. If a callback isn't provided a promise will be returned.

docker.run('ubuntu', ['bash', '-c', 'uname -a'], [process.stdout, process.stderr], {Tty:false}, function (err, data, container) {
  //...
}).on('container', function (container) {
  //...
});

And here is one more complex example using auto-remove and Docker network.

docker.run('some-python-image', ['python', 'main.py', arg], process.stdout, {name: 'my-python-container', HostConfig: { AutoRemove: true, NetworkMode: 'my_network'}}, function(err, data, container) {
  // Do stuff
});

Equivalent of docker pull in dockerode:

  • repoTag - container image name (optionally with tag) myrepo/myname:withtag
  • options - extra options passed to create image.
  • callback - callback called when execution ends.
docker.pull('myrepo/myname:tag', function (err, stream) {
  // streaming output from pull...
});

Pull from private repos

docker-modem already base64 encodes the necessary auth object for you.

var auth = {
  username: 'username',
  password: 'password',
  auth: '',
  email: '[email protected]',
  serveraddress: 'https://index.docker.io/v1'
};

docker.pull('tag', {'authconfig': auth}, function (err, stream) {
  //...
});

If you already have a base64 encoded auth object, you can use it directly:

var auth = { key: 'yJ1J2ZXJhZGRyZXNzIjoitZSI6Im4OCIsImF1dGgiOiIiLCJlbWFpbCI6ImZvbGllLmFkcmc2VybmF0iLCJzZX5jb2aHR0cHM6Ly9pbmRleC5kb2NrZXIuaW8vdZvbGllYSIsInBhc3N3b3JkIjoiRGVjZW1icmUjEvIn0=' }

Helper functions

  • followProgress - allows to fire a callback only in the end of a stream based process. (build, pull, ...)
//followProgress(stream, onFinished, [onProgress])
docker.pull(repoTag, function(err, stream) {
  //...
  docker.modem.followProgress(stream, onFinished, onProgress);

  function onFinished(err, output) {
    //output is an array with output json parsed objects
    //...
  }
  function onProgress(event) {
    //...
  }
});
  • demuxStream - demux stdout and stderr
//demuxStream(stream, stdout, stderr)
container.attach({
  stream: true,
  stdout: true,
  stderr: true
}, function handler(err, stream) {
  //...
  container.modem.demuxStream(stream, process.stdout, process.stderr);
  //...
});

Sponsors

Amazing entities that sponsor my open-source work. Check them out!

HTTP Toolkit

Documentation

Docker

Container

Exec

Image

Network

Node

Plugin

Secret

Service

Task

Volume

Tests

  • docker pull ubuntu:latest to prepare your system for the tests.
  • Tests are implemented using mocha and chai. Run them with npm test.

Examples

Check the examples folder for more specific use cases examples.

License

Pedro Dias - @pedromdias

Licensed under the Apache license, version 2.0 (the "license"); You may not use this file except in compliance with the license. You may obtain a copy of the license at:

http://www.apache.org/licenses/LICENSE-2.0.html

Unless required by applicable law or agreed to in writing, software distributed under the license is distributed on an "as is" basis, without warranties or conditions of any kind, either express or implied. See the license for the specific language governing permissions and limitations under the license.

More Repositories

1

restai

RestAI is an AIaaS (AI as a Service) open-source platform. Built on top of LlamaIndex, Ollama and HF Pipelines. Supports any public LLM supported by LlamaIndex and any local LLM suported by Ollama. Precise embeddings usage and tuning.
Python
355
star
2

docker-modem

Docker Remote API network stack driver.
JavaScript
230
star
3

dockerode-compose

docker-compose in Node.js using dockerode
JavaScript
141
star
4

node-whmcs

WHMCS's API Node.js client
JavaScript
87
star
5

firecrackerode

Firecracker + Node = Firecrackerode (Node.js module for Amazon's Firecracker MicroVM platform)
JavaScript
23
star
6

nodechecker.com

Nodechecker website nodechecker.com
CSS
23
star
7

restai-frontend

RestAI's Frontend
JavaScript
18
star
8

outkept

Auto-discover, reactive monitoring platform.
JavaScript
11
star
9

dashode

Simple HTTP daemon realtime web dashboard for clf based webservers.
JavaScript
11
star
10

dashode2

Realtime dashboard for nginx and other clf based webservers.
JavaScript
9
star
11

wireguarode

Wireguard with ACLs and TOTP 2FA
JavaScript
6
star
12

asusipmiploiter

ASUS iKVM/IPMI password disclosure PoC
Java
6
star
13

ipmifinder

Fast multi-threaded IPMI finder [tool]
Java
6
star
14

node-olx

JavaScript
6
star
15

lxjs-dns

Docker.io LXJS workshop DNS Server
JavaScript
5
star
16

puppet-cpanel

Stripped down generic cPanel installation Puppet module.
Puppet
5
star
17

statode

Node.js email driven status page
CSS
4
star
18

ssh2-multiplexer

SSH2 exec channel queuer/multiplexer/backpressure
JavaScript
4
star
19

realtimechat

Quick and dirty internal full JS web realtime chat using node.JS+socket.IO+Redis
JavaScript
3
star
20

nodechecker-engine

Nodechecker.com engine
JavaScript
3
star
21

capi

Python daemon that watches and dispatch fresh entries in your logs to Redis
Python
3
star
22

swiffy-jquery

Google Swiffy runtime updated to be compatible with jQuery
JavaScript
2
star
23

botbeans

Botbeans, Meet and greet programming.
Java
2
star
24

massconsole

Light and dependency free, SSH Mass Console [tool]
Java
2
star
25

nodechecker-crawler

Nodechecker.com NPM crawler
JavaScript
2
star
26

npmjs.pt

NPM mirror hosted in Portugal
CSS
2
star
27

email2sms

JavaScript
2
star
28

langchain_sysadmin

LangChain GPT based sysadmin assistant
Python
2
star
29

node-logicboxes

Nodejs module for Logicboxes HTTP API - https://manage.logicboxes.com/kb/answer/751
JavaScript
1
star
30

incept-cli

incept-cli
JavaScript
1
star
31

shipode

Node.js based CLF log shipper.
JavaScript
1
star
32

node-onapp

Onapp client implementation in node.js
JavaScript
1
star
33

outke.pt

Outkept website - http://outke.pt
CSS
1
star
34

nodechecker-janitor

JavaScript
1
star
35

incept-drone

incept-drone
JavaScript
1
star
36

establish

Establish
JavaScript
1
star
37

langchain_ingest

Python
1
star
38

node-moss

MOSS node.js assignment
JavaScript
1
star
39

nodechecker-processor

JavaScript
1
star
40

node-nocps

NOC-PS xml-rpc node.js wrapper
JavaScript
1
star
41

incept-balancer

incept-balancer
JavaScript
1
star
42

outkept-dashboard

Outkept's Dashboard
HTML
1
star
43

outkept-handbook

http://outke.pt documentation.
1
star
44

botbeans_bot

Botbeans internal robot code.
Java
1
star
45

netboxvms

Export and sync VM metadata from multiple platforms to Netbox.
JavaScript
1
star
46

outkept_core

Old Java Outkept daemon (deprecated)
Java
1
star
47

nodechecker-api

Nodechecker.com API
JavaScript
1
star
48

node-supportpal

Node.js client for SupportPal help desk.
JavaScript
1
star
49

incept-router

incept-router
JavaScript
1
star
50

nodechecker-balancer

Nodechecker.com nodes load balancer
JavaScript
1
star
51

urbaneous

urbaneous.com events aggregator
JavaScript
1
star