docker: fixes & add username parameter.

docs/ansible.rst

@@ -467,10 +467,10 @@ Sudo
 Docker
 ~~~~~~
 
-Docker support has received relatively little testing, expect increased
+Docker support is fairly new, expect increased surprises for now.
-probability of surprises for the time being.
 
-* ``ansible_host``
+* ``ansible_host``: Name of Docker container.
+* ``ansible_user``: Name of user within the container to execute as.
 
 
 Debugging

mitogen/core.py

@@ -485,6 +485,7 @@ class Importer(object):
         self._present = {'mitogen': [
             'compat',
             'debug',
+            'docker',
             'fakessh',
             'fork',
             'master',

mitogen/docker.py

@@ -38,9 +38,12 @@ LOG = logging.getLogger(__name__)
 class Stream(mitogen.parent.Stream):
     container = None
     image = None
+    username = None
     docker_path = 'docker'
 
-    def construct(self, container=None, image=None, docker_path=None, **kwargs):
+    def construct(self, container=None, image=None,
+                  docker_path=None, username=None,
+                  **kwargs):
         assert container or image
         super(Stream, self).construct(**kwargs)
         if container:
@@ -49,16 +52,22 @@ class Stream(mitogen.parent.Stream):
             self.image = image
         if docker_path:
             self.docker_path = docker_path
+        if username:
+            self.username = username
 
     def connect(self):
         super(Stream, self).connect()
         self.name = 'docker.' + (self.container or self.image)
 
     def get_boot_command(self):
+        args = ['--interactive']
+        if self.username:
+            args += ['--user=' + self.username]
+
         bits = [self.docker_path]
         if self.container:
-            bits += ['exec', '-i', self.container]
+            bits += ['exec'] + args + [self.container]
         elif self.image:
-            bits += ['run', '-i', '--rm', self.image]
+            bits += ['run'] + args + ['--rm', self.image]
-        bits += super(Stream, self).get_boot_command()
+
-        return bits
+        return bits + super(Stream, self).get_boot_command()