Async, event-driven access to the Docker Engine API, built on top of ReactPHP.
Docker is a popular open source platform to run and share applications within isolated, lightweight containers. The Docker Engine API allows you to control and monitor your containers and images. Among others, it can be used to list existing images, download new images, execute arbitrary commands within isolated containers, stop running containers and much more. This lightweight library provides an efficient way to work with the Docker Engine API from within PHP. It enables you to work with its images and containers or use its event-driven model to react to changes and events happening.
- Async execution of Actions - Send any number of actions (commands) to your Docker daemon in parallel and process their responses as soon as results come in. The Promise-based design provides a sane interface to working with out of order responses.
- Lightweight, SOLID design - Provides a thin abstraction that is just good enough and does not get in your way. This library is merely a very thin wrapper around the Docker Engine API.
- Good test coverage - Comes with an automated tests suite and is regularly tested in the real world.
Table of contents
We invest a lot of time developing, maintaining and updating our awesome open-source projects. You can help us sustain this high-quality of our work by becoming a sponsor on GitHub. Sponsors get numerous benefits in return, see our sponsoring page for details.
Let's take these projects to the next level together! 🚀
Once installed, you can use the following code to access the Docker API of your local docker daemon:
<?php
require __DIR__ . '/vendor/autoload.php';
$client = new Clue\React\Docker\Client();
$client->imageSearch('clue')->then(function (array $images) {
var_dump($images);
}, function (Exception $e) {
echo 'Error: ' . $e->getMessage() . PHP_EOL;
});See also the examples.
The Client is responsible for assembling and sending HTTP requests to the Docker Engine API.
$client = new Clue\React\Docker\Client();This class takes an optional LoopInterface|null $loop parameter that can be used to
pass the event loop instance to use for this object. You can use a null value
here in order to use the default loop.
This value SHOULD NOT be given unless you're sure you want to explicitly use a
given event loop instance.
If your Docker Engine API is not accessible using the default unix:///var/run/docker.sock
Unix domain socket path, you may optionally pass an explicit URL like this:
// explicitly use given UNIX socket path
$client = new Clue\React\Docker\Client(null, 'unix:///var/run/docker.sock');
// or connect via TCP/IP to a remote Docker Engine API
$client = new Clue\React\Docker\Client(null, 'http://10.0.0.2:8000/');All public methods on the Client resemble the API described in the Docker Engine API documentation like this:
$client->containerList($all, $size);
$client->containerCreate($config, $name);
$client->containerStart($name);
$client->containerKill($name, $signal);
$client->containerRemove($name, $v, $force);
$client->imageList($all);
$client->imageSearch($term);
$client->imageCreate($fromImage, $fromSrc, $repo, $tag, $registry, $registryAuth);
$client->info();
$client->version();
// many, many more…Listing all available commands is out of scope here, please refer to the Docker Engine API documentation or the class outline.
Each of these commands supports async operation and either resolves with its results
or rejects with an Exception.
Please see the following section about promises for more details.
Sending requests is async (non-blocking), so you can actually send multiple requests in parallel. Docker will respond to each request with a response message, the order is not guaranteed. Sending requests uses a Promise-based interface that makes it easy to react to when a command is completed (i.e. either successfully fulfilled or rejected with an error):
$client->version()->then(
function ($result) {
var_dump('Result received', $result);
},
function (Exception $e) {
echo 'Error: ' . $e->getMessage() . PHP_EOL;
}
});If this looks strange to you, you can also use the more traditional blocking API.
As stated above, this library provides you a powerful, async API by default.
You can also integrate this into your traditional, blocking environment by using reactphp/async. This allows you to simply await commands on the client like this:
use function React\Async\await;
$client = new Clue\React\Docker\Client();
$promise = $client->imageInspect('busybox');
try {
$results = await($promise);
// results successfully received
} catch (Exception $e) {
// an error occurred while performing the request
}Similarly, you can also process multiple commands concurrently and await an array of results:
use function React\Async\await;
use function React\Promise\all;
$promises = array(
$client->imageInspect('busybox'),
$client->imageInspect('ubuntu'),
);
$inspections = await(all($promises));This is made possible thanks to fibers available in PHP 8.1+ and our compatibility API that also works on all supported PHP versions. Please refer to reactphp/async for more details.
The following API endpoints resolve with a buffered string of the command output (STDOUT and/or STDERR):
$client->containerAttach($container);
$client->containerLogs($container);
$client->execStart($exec);Keep in mind that this means the whole string has to be kept in memory. If you want to access the individual output chunks as they happen or for bigger command outputs, it's usually a better idea to use a streaming approach.
This works for (any number of) commands of arbitrary sizes.
The following API endpoints complement the default Promise-based API and return
a Stream instance instead:
$stream = $client->containerAttachStream($container);
$stream = $client->containerLogsStream($container);
$stream = $client->execStartStream($exec);The resulting stream is a well-behaving readable stream that will emit the normal stream events:
$stream = $client->execStartStream($exec, $tty);
$stream->on('data', function ($data) {
// data will be emitted in multiple chunk
echo $data;
});
$stream->on('error', function (Exception $e) {
echo 'Error: ' . $e->getMessage() . PHP_EOL;
});
$stream->on('close', function () {
// the stream just ended, this could(?) be a good thing
echo 'Ended' . PHP_EOL;
});Note that by default the output of both STDOUT and STDERR will be emitted
as normal data events. You can optionally pass a custom event name which
will be used to emit STDERR data so that it can be handled separately.
Note that the normal streaming primitives likely do not know about this
event, so special care may have to be taken.
Also note that this option has no effect if you execute with a TTY.
$stream = $client->execStartStream($exec, $tty, 'stderr');
$stream->on('data', function ($data) {
echo 'STDOUT data: ' . $data;
});
$stream->on('stderr', function ($data) {
echo 'STDERR data: ' . $data;
});See also the streaming exec example and the exec benchmark example.
The TTY mode should be set depending on whether your command needs a TTY
or not. Note that toggling the TTY mode affects how/whether you can access
the STDERR stream and also has a significant impact on performance for
larger streams (relevant for hundreds of megabytes and more). See also the TTY
mode on the execStart*() call.
Running the provided benchmark example on a range of systems, it suggests that this library can process several gigabytes per second and may in fact outperform the Docker client and seems to be limited only by the Docker Engine implementation. Instead of posting more details here, you're encouraged to re-run the benchmarks yourself and see for yourself. The key takeway here is: PHP is faster than you probably thought.
The following API endpoints resolve with a string in the TAR file format:
$client->containerExport($container);
$client->containerArchive($container, $path);Keep in mind that this means the whole string has to be kept in memory. This is easy to get started and works reasonably well for smaller files/containers.
For bigger containers it's usually a better idea to use a streaming approach,
where only small chunks have to be kept in memory.
This works for (any number of) files of arbitrary sizes.
The following API endpoints complement the default Promise-based API and return
a Stream instance instead:
$stream = $client->containerExportStream($image);
$stream = $client->containerArchiveStream($container, $path);Accessing individual files in the TAR file format string or stream is out of scope for this library. Several libraries are available, one that is known to work is clue/reactphp-tar.
See also the archive example and the export example.
The following API endpoints take advantage of JSON streaming:
$client->imageCreate();
$client->imagePush();
$client->events();What this means is that these endpoints actually emit any number of progress events (individual JSON objects). At the HTTP level, a common response message could look like this:
HTTP/1.1 200 OK
Content-Type: application/json
{"status":"loading","current":1,"total":10}
{"status":"loading","current":2,"total":10}
…
{"status":"loading","current":10,"total":10}
{"status":"done","total":10}
The user-facing API hides this fact by resolving with an array of all individual progress events once the stream ends:
$client->imageCreate('clue/streamripper')->then(
function (array $data) {
// $data is an array of *all* elements in the JSON stream
var_dump($data);
},
function (Exception $e) {
// an error occurred (possibly after receiving *some* elements)
echo 'Error: ' . $e->getMessage() . PHP_EOL;
}
);Keep in mind that due to resolving with an array of all progress events, this API has to keep all event objects in memory until the Promise resolves. This is easy to get started and usually works reasonably well for the above API endpoints.
If you're dealing with lots of concurrent requests (100+) or
if you want to access the individual progress events as they happen, you
should consider using a streaming approach instead,
where only individual progress event objects have to be kept in memory.
The following API endpoints complement the default Promise-based API and return
a Stream instance instead:
$stream = $client->imageCreateStream();
$stream = $client->imagePushStream();
$stream = $client->eventsStream();
$stream = $client->containerStatsStream($container);The resulting stream will emit the following events:
data: for each element in the update streamerror: once if an error occurs, will close() stream then- Will emit a
RuntimeExceptionif an individual progress message contains an error message or any otherExceptionin case of an transport error, like invalid request etc.
- Will emit a
close: once the stream ends (either finished or after "error")
$stream = $client->imageCreateStream('clue/redis-benchmark');
$stream->on('data', function (array $data) {
// data will be emitted for *each* complete element in the JSON stream
echo $data['status'] . PHP_EOL;
});
$stream->on('error', function (Exception $e) {
echo 'Error: ' . $e->getMessage() . PHP_EOL;
});
$stream->on('close', function () {
// the JSON stream just ended, this could(?) be a good thing
echo 'Ended' . PHP_EOL;
});See also the pull example and the push example.
The recommended way to install this library is through Composer. New to Composer?
This project follows SemVer. This will install the latest supported version:
composer require clue/docker-react:^1.5See also the CHANGELOG for details about version upgrades.
This project aims to run on any platform and thus does not require any PHP extensions and supports running on legacy PHP 5.3 through current PHP 8+. It's highly recommended to use the latest supported PHP version for this project.
To run the test suite, you first need to clone this repo and then install all dependencies through Composer:
composer installTo run the test suite, go to the project root and run:
vendor/bin/phpunitThis project is released under the permissive MIT license.
Did you know that I offer custom development services and issuing invoices for sponsorships of releases and for contributions? Contact me (@clue) for details.