Skip to content

D
docker-py
Kaydet (Commit) acd26074 authored tarafından shin-'s avatar shin-
Dosyalara gözat
Seçenekler

Flake8 compliance + flake8 tests in tox.ini

üst 86b341dd
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 196 additions and 97 deletions
docker/__init__.py
Dosyayı görüntüle @ acd26074
...@@ -12,4 +12,4 @@ ...@@ -12,4 +12,4 @@
# See the License for the specific language governing permissions and # See the License for the specific language governing permissions and
# limitations under the License. # limitations under the License.
from .client import Client, APIError from .client import Client, APIError # flake8: noqa
docker/auth/__init__.py
Dosyayı görüntüle @ acd26074
from .auth import *
\ No newline at end of file
from .auth import (
INDEX_URL,
encode_header,
load_config,
resolve_authconfig,
resolve_repository_name
) # flake8: noqa
\ No newline at end of file
docker/client.py
Dosyayı görüntüle @ acd26074
...@@ -31,7 +31,7 @@ class APIError(requests.exceptions.HTTPError): ...@@ -31,7 +31,7 @@ class APIError(requests.exceptions.HTTPError):
self.explanation = explanation self.explanation = explanation
if self.explanation is None and response.content and len(response.content) > 0: if self.explanation is None and response.content:
self.explanation = response.content.strip() self.explanation = response.content.strip()
def __str__(self): def __str__(self):
...@@ -86,13 +86,15 @@ class Client(requests.Session): ...@@ -86,13 +86,15 @@ class Client(requests.Session):
return response.text return response.text
def _container_config(self, image, command, hostname=None, user=None, def _container_config(self, image, command, hostname=None, user=None,
detach=False, stdin_open=False, tty=False, mem_limit=0, ports=None, detach=False, stdin_open=False, tty=False,
environment=None, dns=None, volumes=None, volumes_from=None, mem_limit=0, ports=None, environment=None, dns=None,
privileged=False): volumes=None, volumes_from=None, privileged=False):
if isinstance(command, six.string_types): if isinstance(command, six.string_types):
command = shlex.split(str(command)) command = shlex.split(str(command))
if isinstance(environment, dict): if isinstance(environment, dict):
environment = ['{0}={1}'.format(k, v) for k, v in environment.items()] environment = [
'{0}={1}'.format(k, v) for k, v in environment.items()
]
attach_stdin = False attach_stdin = False
attach_stdout = False attach_stdout = False
...@@ -166,25 +168,31 @@ class Client(requests.Session): ...@@ -166,25 +168,31 @@ class Client(requests.Session):
else: else:
break break
def build(self, path=None, tag=None, quiet=False, fileobj=None, nocache=False, rm=False): def build(self, path=None, tag=None, quiet=False, fileobj=None,
nocache=False, rm=False):
remote = context = headers = None remote = context = headers = None
if path is None and fileobj is None: if path is None and fileobj is None:
raise Exception("Either path or fileobj needs to be provided.") raise Exception("Either path or fileobj needs to be provided.")
if fileobj is not None: if fileobj is not None:
context = utils.mkbuildcontext(fileobj) context = utils.mkbuildcontext(fileobj)
elif (path.startswith('http://') or path.startswith('https://') or elif path.startswith(('http://', 'https://', 'git://', 'github.com/')):
path.startswith('git://') or path.startswith('github.com/')):
remote = path remote = path
else: else:
context = utils.tar(path) context = utils.tar(path)
u = self._url('/build') u = self._url('/build')
params = { 't': tag, 'remote': remote, 'q': quiet, 'nocache': nocache, 'rm': rm } params = {
't': tag,
'remote': remote,
'q': quiet,
'nocache': nocache,
'rm': rm
}
if context is not None: if context is not None:
headers = { 'Content-Type': 'application/tar' } headers = {'Content-Type': 'application/tar'}
res = self._result(self.post(u, context, params=params, res = self._result(self.post(u, context, params=params,
headers=headers, stream=True)) headers=headers, stream=True))
if context is not None: if context is not None:
context.close() context.close()
srch = r'Successfully built ([0-9a-f]+)' srch = r'Successfully built ([0-9a-f]+)'
...@@ -194,7 +202,7 @@ class Client(requests.Session): ...@@ -194,7 +202,7 @@ class Client(requests.Session):
return match.group(1), res return match.group(1), res
def commit(self, container, repository=None, tag=None, message=None, def commit(self, container, repository=None, tag=None, message=None,
author=None, conf=None): author=None, conf=None):
params = { params = {
'container': container, 'container': container,
'repo': repository, 'repo': repository,
...@@ -206,7 +214,7 @@ class Client(requests.Session): ...@@ -206,7 +214,7 @@ class Client(requests.Session):
return self._result(self._post_json(u, conf, params=params), json=True) return self._result(self._post_json(u, conf, params=params), json=True)
def containers(self, quiet=False, all=False, trunc=True, latest=False, def containers(self, quiet=False, all=False, trunc=True, latest=False,
since=None, before=None, limit=-1): since=None, before=None, limit=-1):
params = { params = {
'limit': 1 if latest else limit, 'limit': 1 if latest else limit,
'all': 1 if all else 0, 'all': 1 if all else 0,
...@@ -217,25 +225,27 @@ class Client(requests.Session): ...@@ -217,25 +225,27 @@ class Client(requests.Session):
u = self._url("/containers/ps") u = self._url("/containers/ps")
res = self._result(self.get(u, params=params), True) res = self._result(self.get(u, params=params), True)
if quiet: if quiet:
return [{ 'Id': x['Id'] } for x in res] return [{'Id': x['Id']} for x in res]
return res return res
def copy(self, container, resource): def copy(self, container, resource):
res = self._post_json(self._url("/containers/{0}/copy".format(container)), res = self._post_json(
self._url("/containers/{0}/copy".format(container)),
{"Resource": resource}, {"Resource": resource},
stream=True) stream=True
)
self._raise_for_status(res) self._raise_for_status(res)
return res.raw return res.raw
def create_container(self, image, command, hostname=None, user=None, def create_container(self, image, command, hostname=None, user=None,
detach=False, stdin_open=False, tty=False, mem_limit=0, ports=None, detach=False, stdin_open=False, tty=False,
environment=None, dns=None, volumes=None, volumes_from=None, mem_limit=0, ports=None, environment=None, dns=None,
privileged=False): volumes=None, volumes_from=None, privileged=False):
config = self._container_config(
config = self._container_config(image, command, hostname, user, image, command, hostname, user, detach, stdin_open, tty, mem_limit,
detach, stdin_open, tty, mem_limit, ports, environment, dns, ports, environment, dns, volumes, volumes_from, privileged
volumes, volumes_from, privileged) )
return self.create_container_from_config(config) return self.create_container_from_config(config)
def create_container_from_config(self, config): def create_container_from_config(self, config):
...@@ -247,13 +257,13 @@ class Client(requests.Session): ...@@ -247,13 +257,13 @@ class Client(requests.Session):
if isinstance(container, dict): if isinstance(container, dict):
container = container.get('Id') container = container.get('Id')
return self._result(self.get(self._url("/containers/{0}/changes". return self._result(self.get(self._url("/containers/{0}/changes".
format(container))), True) format(container))), True)
def export(self, container): def export(self, container):
if isinstance(container, dict): if isinstance(container, dict):
container = container.get('Id') container = container.get('Id')
res = self.get(self._url("/containers/{0}/export".format(container)), res = self.get(self._url("/containers/{0}/export".format(container)),
stream=True) stream=True)
self._raise_for_status(res) self._raise_for_status(res)
return res.raw return res.raw
...@@ -271,7 +281,7 @@ class Client(requests.Session): ...@@ -271,7 +281,7 @@ class Client(requests.Session):
'all': 1 if all else 0, 'all': 1 if all else 0,
} }
res = self._result(self.get(self._url("/images/json"), params=params), res = self._result(self.get(self._url("/images/json"), params=params),
True) True)
if quiet: if quiet:
return [x['Id'] for x in res] return [x['Id'] for x in res]
return res return res
...@@ -312,12 +322,14 @@ class Client(requests.Session): ...@@ -312,12 +322,14 @@ class Client(requests.Session):
def inspect_container(self, container): def inspect_container(self, container):
if isinstance(container, dict): if isinstance(container, dict):
container = container.get('Id') container = container.get('Id')
return self._result(self.get(self._url("/containers/{0}/json". return self._result(self.get(
format(container))), True) self._url("/containers/{0}/json".format(container))
), True)
def inspect_image(self, image_id): def inspect_image(self, image_id):
return self._result(self.get(self._url("/images/{0}/json". return self._result(self.get(
format(image_id))), True) self._url("/images/{0}/json".format(image_id))
), True)
def kill(self, container): def kill(self, container):
if isinstance(container, dict): if isinstance(container, dict):
...@@ -411,7 +423,7 @@ class Client(requests.Session): ...@@ -411,7 +423,7 @@ class Client(requests.Session):
def remove_container(self, container, v=False): def remove_container(self, container, v=False):
if isinstance(container, dict): if isinstance(container, dict):
container = container.get('Id') container = container.get('Id')
params = { 'v': v } params = {'v': v}
res = self.delete(self._url("/containers/" + container), params=params) res = self.delete(self._url("/containers/" + container), params=params)
self._raise_for_status(res) self._raise_for_status(res)
...@@ -422,14 +434,14 @@ class Client(requests.Session): ...@@ -422,14 +434,14 @@ class Client(requests.Session):
def restart(self, container, timeout=10): def restart(self, container, timeout=10):
if isinstance(container, dict): if isinstance(container, dict):
container = container.get('Id') container = container.get('Id')
params = { 't': timeout } params = {'t': timeout}
url = self._url("/containers/{0}/restart".format(container)) url = self._url("/containers/{0}/restart".format(container))
res = self.post(url, None, params=params) res = self.post(url, None, params=params)
self._raise_for_status(res) self._raise_for_status(res)
def search(self, term): def search(self, term):
return self._result(self.get(self._url("/images/search"), return self._result(self.get(self._url("/images/search"),
params={'term': term}), True) params={'term': term}), True)
def start(self, container, binds=None, lxc_conf=None): def start(self, container, binds=None, lxc_conf=None):
if isinstance(container, dict): if isinstance(container, dict):
...@@ -438,7 +450,9 @@ class Client(requests.Session): ...@@ -438,7 +450,9 @@ class Client(requests.Session):
'LxcConf': lxc_conf 'LxcConf': lxc_conf
} }
if binds: if binds:
bind_pairs = ['{0}:{1}'.format(host, dest) for host, dest in binds.items()] bind_pairs = [
'{0}:{1}'.format(host, dest) for host, dest in binds.items()
]
start_config['Binds'] = bind_pairs start_config['Binds'] = bind_pairs
url = self._url("/containers/{0}/start".format(container)) url = self._url("/containers/{0}/start".format(container))
...@@ -448,7 +462,7 @@ class Client(requests.Session): ...@@ -448,7 +462,7 @@ class Client(requests.Session):
def stop(self, container, timeout=10): def stop(self, container, timeout=10):
if isinstance(container, dict): if isinstance(container, dict):
container = container.get('Id') container = container.get('Id')
params = { 't': timeout } params = {'t': timeout}
url = self._url("/containers/{0}/stop".format(container)) url = self._url("/containers/{0}/stop".format(container))
res = self.post(url, None, params=params) res = self.post(url, None, params=params)
self._raise_for_status(res) self._raise_for_status(res)
......
docker/unixconn/__init__.py
Dosyayı görüntüle @ acd26074
from .unixconn import UnixAdapter from .unixconn import UnixAdapter # flake8: noqa
docker/utils/__init__.py
Dosyayı görüntüle @ acd26074
from .utils import mkbuildcontext, tar, compare_version from .utils import mkbuildcontext, tar, compare_version # flake8: noqa
tests/fake_api.py
Dosyayı görüntüle @ acd26074
import json # Copyright 2013 dotCloud inc.
# 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
# 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.
CURRENT_VERSION = 'v1.4' CURRENT_VERSION = 'v1.4'
...@@ -30,21 +42,24 @@ def get_fake_search(): ...@@ -30,21 +42,24 @@ def get_fake_search():
def get_fake_images(): def get_fake_images():
status_code = 200 status_code = 200
response = [ response = [{
{'Id': FAKE_IMAGE_ID, 'Created': '2 days ago', 'Repository': 'busybox', 'Tag': 'latest'} 'Id': FAKE_IMAGE_ID,
] 'Created': '2 days ago',
'Repository': 'busybox',
'Tag': 'latest'
}]
return status_code, response return status_code, response
def get_fake_containers(): def get_fake_containers():
status_code = 200 status_code = 200
response = [ response = [{
{'Id': FAKE_CONTAINER_ID, 'Id': FAKE_CONTAINER_ID,
'Image': 'busybox:latest', 'Image': 'busybox:latest',
'Created': '2 days ago', 'Created': '2 days ago',
'Command': 'true', 'Command': 'true',
'Status': 'fake status'} 'Status': 'fake status'
] }]
return status_code, response return status_code, response
...@@ -67,7 +82,7 @@ def get_fake_inspect_container(): ...@@ -67,7 +82,7 @@ def get_fake_inspect_container():
'Config': {'Privileged': True}, 'Config': {'Privileged': True},
'ID': FAKE_CONTAINER_ID, 'ID': FAKE_CONTAINER_ID,
'Image': 'busybox:latest', 'Image': 'busybox:latest',
"State": { "State": {
"Running": True, "Running": True,
"Pid": 0, "Pid": 0,
"ExitCode": 0, "ExitCode": 0,
...@@ -145,24 +160,44 @@ def post_fake_build_container(): ...@@ -145,24 +160,44 @@ def post_fake_build_container():
## maps real api url to fake response callback ## maps real api url to fake response callback
prefix = 'unix://var/run/docker.sock'
fake_responses = { fake_responses = {
'unix://var/run/docker.sock/{0}/version'.format(CURRENT_VERSION): get_fake_version, '{1}/{0}/version'.format(CURRENT_VERSION, prefix):
'unix://var/run/docker.sock/{0}/info'.format(CURRENT_VERSION): get_fake_info, get_fake_version,
'unix://var/run/docker.sock/{0}/images/search'.format(CURRENT_VERSION): get_fake_search, '{1}/{0}/info'.format(CURRENT_VERSION, prefix):
'unix://var/run/docker.sock/{0}/images/json'.format(CURRENT_VERSION): get_fake_images, get_fake_info,
'unix://var/run/docker.sock/{0}/containers/ps'.format(CURRENT_VERSION): get_fake_containers, '{1}/{0}/images/search'.format(CURRENT_VERSION, prefix):
'unix://var/run/docker.sock/{0}/containers/3cc2351ab11b/start'.format(CURRENT_VERSION): post_fake_start_container, get_fake_search,
'unix://var/run/docker.sock/{0}/containers/3cc2351ab11b/json'.format(CURRENT_VERSION): get_fake_inspect_container, '{1}/{0}/images/json'.format(CURRENT_VERSION, prefix):
'unix://var/run/docker.sock/{0}/containers/3cc2351ab11b/wait'.format(CURRENT_VERSION): get_fake_wait, get_fake_images,
'unix://var/run/docker.sock/{0}/containers/3cc2351ab11b/attach'.format(CURRENT_VERSION): get_fake_logs, '{1}/{0}/containers/ps'.format(CURRENT_VERSION, prefix):
'unix://var/run/docker.sock/{0}/containers/3cc2351ab11b/changes'.format(CURRENT_VERSION): get_fake_diff, get_fake_containers,
'unix://var/run/docker.sock/{0}/containers/3cc2351ab11b/stop'.format(CURRENT_VERSION): post_fake_stop_container, '{1}/{0}/containers/3cc2351ab11b/start'.format(CURRENT_VERSION, prefix):
'unix://var/run/docker.sock/{0}/containers/3cc2351ab11b/kill'.format(CURRENT_VERSION): post_fake_kill_container, post_fake_start_container,
'unix://var/run/docker.sock/{0}/containers/3cc2351ab11b/restart'.format(CURRENT_VERSION): post_fake_restart_container, '{1}/{0}/containers/3cc2351ab11b/json'.format(CURRENT_VERSION, prefix):
'unix://var/run/docker.sock/{0}/containers/3cc2351ab11b'.format(CURRENT_VERSION): delete_fake_remove_container, get_fake_inspect_container,
'unix://var/run/docker.sock/{0}/images/create'.format(CURRENT_VERSION): post_fake_image_create, '{1}/{0}/containers/3cc2351ab11b/wait'.format(CURRENT_VERSION, prefix):
'unix://var/run/docker.sock/{0}/images/e9aa60c60128'.format(CURRENT_VERSION): delete_fake_remove_image, get_fake_wait,
'unix://var/run/docker.sock/{0}/commit'.format(CURRENT_VERSION): post_fake_commit, '{1}/{0}/containers/3cc2351ab11b/attach'.format(CURRENT_VERSION, prefix):
'unix://var/run/docker.sock/{0}/containers/create'.format(CURRENT_VERSION): post_fake_create_container, get_fake_logs,
'unix://var/run/docker.sock/{0}/build'.format(CURRENT_VERSION): post_fake_build_container '{1}/{0}/containers/3cc2351ab11b/changes'.format(CURRENT_VERSION, prefix):
get_fake_diff,
'{1}/{0}/containers/3cc2351ab11b/stop'.format(CURRENT_VERSION, prefix):
post_fake_stop_container,
'{1}/{0}/containers/3cc2351ab11b/kill'.format(CURRENT_VERSION, prefix):
post_fake_kill_container,
'{1}/{0}/containers/3cc2351ab11b/restart'.format(CURRENT_VERSION, prefix):
post_fake_restart_container,
'{1}/{0}/containers/3cc2351ab11b'.format(CURRENT_VERSION, prefix):
delete_fake_remove_container,
'{1}/{0}/images/create'.format(CURRENT_VERSION, prefix):
post_fake_image_create,
'{1}/{0}/images/e9aa60c60128'.format(CURRENT_VERSION, prefix):
delete_fake_remove_image,
'{1}/{0}/commit'.format(CURRENT_VERSION, prefix):
post_fake_commit,
'{1}/{0}/containers/create'.format(CURRENT_VERSION, prefix):
post_fake_create_container,
'{1}/{0}/build'.format(CURRENT_VERSION, prefix):
post_fake_build_container
} }
tests/integration_test.py
Dosyayı görüntüle @ acd26074
This diff is collapsed.
tests/test.py
Dosyayı görüntüle @ acd26074
...@@ -60,7 +60,8 @@ def fake_resp(url, data=None, **kwargs): ...@@ -60,7 +60,8 @@ def fake_resp(url, data=None, **kwargs):
fake_request = mock.Mock(side_effect=fake_resp) fake_request = mock.Mock(side_effect=fake_resp)
@mock.patch.multiple('docker.Client', get=fake_request, post=fake_request, put=fake_request, delete=fake_request) @mock.patch.multiple('docker.Client', get=fake_request, post=fake_request,
put=fake_request, delete=fake_request)
class DockerClientTest(unittest.TestCase): class DockerClientTest(unittest.TestCase):
def setUp(self): def setUp(self):
self.client = docker.Client() self.client = docker.Client()
...@@ -74,7 +75,9 @@ class DockerClientTest(unittest.TestCase): ...@@ -74,7 +75,9 @@ class DockerClientTest(unittest.TestCase):
except Exception as e: except Exception as e:
self.fail('Command should not raise exception: {0}'.format(e)) self.fail('Command should not raise exception: {0}'.format(e))
fake_request.assert_called_with('unix://var/run/docker.sock/v1.4/version') fake_request.assert_called_with(
'unix://var/run/docker.sock/v1.4/version'
)
def test_info(self): def test_info(self):
try: try:
...@@ -90,8 +93,10 @@ class DockerClientTest(unittest.TestCase): ...@@ -90,8 +93,10 @@ class DockerClientTest(unittest.TestCase):
except Exception as e: except Exception as e:
self.fail('Command should not raise exception: {0}'.format(e)) self.fail('Command should not raise exception: {0}'.format(e))
fake_request.assert_called_with('unix://var/run/docker.sock/v1.4/images/search', fake_request.assert_called_with(
params={'term': 'busybox'}) 'unix://var/run/docker.sock/v1.4/images/search',
params={'term': 'busybox'}
)
################### ###################
## LISTING TESTS ## ## LISTING TESTS ##
...@@ -102,8 +107,10 @@ class DockerClientTest(unittest.TestCase): ...@@ -102,8 +107,10 @@ class DockerClientTest(unittest.TestCase):
self.client.images(all=True) self.client.images(all=True)
except Exception as e: except Exception as e:
self.fail('Command should not raise exception: {0}'.format(e)) self.fail('Command should not raise exception: {0}'.format(e))
fake_request.assert_called_with('unix://var/run/docker.sock/v1.4/images/json', fake_request.assert_called_with(
params={'filter': None, 'only_ids': 0, 'all': 1}) 'unix://var/run/docker.sock/v1.4/images/json',
params={'filter': None, 'only_ids': 0, 'all': 1}
)
def test_image_ids(self): def test_image_ids(self):
try: try:
...@@ -111,8 +118,10 @@ class DockerClientTest(unittest.TestCase): ...@@ -111,8 +118,10 @@ class DockerClientTest(unittest.TestCase):
except Exception as e: except Exception as e:
self.fail('Command should not raise exception: {0}'.format(e)) self.fail('Command should not raise exception: {0}'.format(e))
fake_request.assert_called_with('unix://var/run/docker.sock/v1.4/images/json', fake_request.assert_called_with(
params={'filter': None, 'only_ids': 1, 'all': 0}) 'unix://var/run/docker.sock/v1.4/images/json',
params={'filter': None, 'only_ids': 1, 'all': 0}
)
def test_list_containers(self): def test_list_containers(self):
try: try:
...@@ -120,7 +129,8 @@ class DockerClientTest(unittest.TestCase): ...@@ -120,7 +129,8 @@ class DockerClientTest(unittest.TestCase):
except Exception as e: except Exception as e:
self.fail('Command should not raise exception: {0}'.format(e)) self.fail('Command should not raise exception: {0}'.format(e))
fake_request.assert_called_with('unix://var/run/docker.sock/v1.4/containers/ps', fake_request.assert_called_with(
'unix://var/run/docker.sock/v1.4/containers/ps',
params={ params={
'all': 1, 'all': 1,
'since': None, 'since': None,
...@@ -141,35 +151,57 @@ class DockerClientTest(unittest.TestCase): ...@@ -141,35 +151,57 @@ class DockerClientTest(unittest.TestCase):
self.fail('Command should not raise exception: {0}'.format(e)) self.fail('Command should not raise exception: {0}'.format(e))
args = fake_request.call_args args = fake_request.call_args
self.assertEqual(args[0][0], 'unix://var/run/docker.sock/v1.4/containers/create') self.assertEqual(args[0][0],
self.assertEqual(json.loads(args[0][1]), json.loads('{"Tty": false, "Image": "busybox", "Cmd": ["true"], "AttachStdin": false, "Memory": 0, "AttachStderr": true, "Privileged": false, "AttachStdout": true, "OpenStdin": false}')) 'unix://var/run/docker.sock/v1.4/containers/create')
self.assertEqual(args[1]['headers'], {'Content-Type': 'application/json'}) self.assertEqual(json.loads(args[0][1]),
json.loads('''
{"Tty": false, "Image": "busybox", "Cmd": ["true"],
"AttachStdin": false, "Memory": 0,
"AttachStderr": true, "Privileged": false,
"AttachStdout": true, "OpenStdin": false}'''))
self.assertEqual(args[1]['headers'],
{'Content-Type': 'application/json'})
def test_create_container_with_binds(self): def test_create_container_with_binds(self):
mount_dest = '/mnt' mount_dest = '/mnt'
mount_origin = '/tmp' #mount_origin = '/tmp'
try: try:
self.client.create_container('busybox', self.client.create_container('busybox', ['ls', mount_dest],
['ls', mount_dest], volumes={mount_dest: {}}) volumes={mount_dest: {}})
except Exception as e: except Exception as e:
self.fail('Command should not raise exception: {0}'.format(e)) self.fail('Command should not raise exception: {0}'.format(e))
args = fake_request.call_args args = fake_request.call_args
self.assertEqual(args[0][0], 'unix://var/run/docker.sock/v1.4/containers/create') self.assertEqual(args[0][0],
self.assertEqual(json.loads(args[0][1]), json.loads('{"Tty": false, "Image": "busybox", "Cmd": ["ls", "/mnt"], "AttachStdin": false, "Volumes": {"/mnt": {}}, "Memory": 0, "AttachStderr": true, "Privileged": false, "AttachStdout": true, "OpenStdin": false}')) 'unix://var/run/docker.sock/v1.4/containers/create')
self.assertEqual(args[1]['headers'], {'Content-Type': 'application/json'}) self.assertEqual(json.loads(args[0][1]),
json.loads('''
{"Tty": false, "Image": "busybox",
"Cmd": ["ls", "/mnt"], "AttachStdin": false,
"Volumes": {"/mnt": {}}, "Memory": 0,
"AttachStderr": true, "Privileged": false,
"AttachStdout": true, "OpenStdin": false}'''))
self.assertEqual(args[1]['headers'],
{'Content-Type': 'application/json'})
def test_create_container_privileged(self): def test_create_container_privileged(self):
try: try:
self.client.create_container('busybox', 'true', privileged=True) self.client.create_container('busybox', 'true', privileged=True)
except Exception as e: except Exception as e:
self.fail('Command should not raise exception: {0}'.format(e)) self.fail('Command should not raise exception: {0}'.format(e))
args = fake_request.call_args args = fake_request.call_args
self.assertEqual(args[0][0], 'unix://var/run/docker.sock/v1.4/containers/create') self.assertEqual(args[0][0],
self.assertEqual(json.loads(args[0][1]), json.loads('{"Tty": false, "Image": "busybox", "Cmd": ["true"], "AttachStdin": false, "Memory": 0, "AttachStderr": true, "Privileged": true, "AttachStdout": true, "OpenStdin": false}')) 'unix://var/run/docker.sock/v1.4/containers/create')
self.assertEqual(args[1]['headers'], {'Content-Type': 'application/json'}) self.assertEqual(json.loads(args[0][1]),
json.loads('''
{"Tty": false, "Image": "busybox", "Cmd": ["true"],
"AttachStdin": false, "Memory": 0,
"AttachStderr": true, "Privileged": true,
"AttachStdout": true, "OpenStdin": false}'''))
self.assertEqual(args[1]['headers'],
{'Content-Type': 'application/json'})
def test_start_container(self): def test_start_container(self):
try: try:
...@@ -187,7 +219,8 @@ class DockerClientTest(unittest.TestCase): ...@@ -187,7 +219,8 @@ class DockerClientTest(unittest.TestCase):
try: try:
mount_dest = '/mnt' mount_dest = '/mnt'
mount_origin = '/tmp' mount_origin = '/tmp'
self.client.start(fake_api.FAKE_CONTAINER_ID, binds={mount_origin: mount_dest}) self.client.start(fake_api.FAKE_CONTAINER_ID,
binds={mount_origin: mount_dest})
except Exception as e: except Exception as e:
self.fail('Command should not raise exception: {0}'.format(e)) self.fail('Command should not raise exception: {0}'.format(e))
...@@ -375,7 +408,8 @@ class DockerClientTest(unittest.TestCase): ...@@ -375,7 +408,8 @@ class DockerClientTest(unittest.TestCase):
except Exception as e: except Exception as e:
self.fail('Command should not raise exception: {0}'.format(e)) self.fail('Command should not raise exception: {0}'.format(e))
fake_request.assert_called_with('unix://var/run/docker.sock/v1.4/images/create', fake_request.assert_called_with(
'unix://var/run/docker.sock/v1.4/images/create',
headers={}, headers={},
params={'tag': None, 'fromImage': 'joffrey/test001'} params={'tag': None, 'fromImage': 'joffrey/test001'}
) )
...@@ -405,7 +439,9 @@ class DockerClientTest(unittest.TestCase): ...@@ -405,7 +439,9 @@ class DockerClientTest(unittest.TestCase):
except Exception as e: except Exception as e:
self.fail('Command should not raise exception: {0}'.format(e)) self.fail('Command should not raise exception: {0}'.format(e))
fake_request.assert_called_with('unix://var/run/docker.sock/v1.4/images/e9aa60c60128') fake_request.assert_called_with(
'unix://var/run/docker.sock/v1.4/images/e9aa60c60128'
)
################# #################
# BUILDER TESTS # # BUILDER TESTS #
...@@ -417,7 +453,8 @@ class DockerClientTest(unittest.TestCase): ...@@ -417,7 +453,8 @@ class DockerClientTest(unittest.TestCase):
'MAINTAINER docker-py', 'MAINTAINER docker-py',
'RUN mkdir -p /tmp/test', 'RUN mkdir -p /tmp/test',
'EXPOSE 8080', 'EXPOSE 8080',
'ADD https://dl.dropboxusercontent.com/u/20637798/silence.tar.gz /tmp/silence.tar.gz' 'ADD https://dl.dropboxusercontent.com/u/20637798/silence.tar.gz'
' /tmp/silence.tar.gz'
]).encode('ascii')) ]).encode('ascii'))
try: try:
self.client.build(fileobj=script) self.client.build(fileobj=script)
......
tox.ini
Dosyayı görüntüle @ acd26074
[tox] [tox]
envlist = py26, py27, py32, py33 envlist = py26, py27, py32, py33, flake8
skipsdist=True skipsdist=True
[testenv] [testenv]
usedevelop=True usedevelop=True
commands = commands =
{envpython} tests/test.py {envpython} tests/test.py
deps = -r{toxinidir}/requirements.txt deps = -r{toxinidir}/requirements.txt
[testenv:flake8]
commands = flake8 docker tests
deps = flake8
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment