docker
/
docker-py
mirror of https://github.com/docker/docker-py.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use websockets by passing 'ws' param to attach_socket

This commit is contained in:
Aanand Prasad 2013-11-06 17:21:41 +00:00
parent cf35b38433
commit bd938b5879
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
docker/client.py
View File

@ -140,7 +140,10 @@ class Client(requests.Session):
kwargs['headers']['Content-Type'] = 'application/json' kwargs['headers']['Content-Type'] = 'application/json'
return self.post(url, json.dumps(data2), **kwargs) return self.post(url, json.dumps(data2), **kwargs)
def attach_socket(self, container, params=None): def attach_socket(self, container, params=None, ws=False):
if ws:
return self._attach_websocket(container, params)
if isinstance(container, dict): if isinstance(container, dict):
container = container.get('Id') container = container.get('Id')
u = self._url("/containers/{0}/attach".format(container)) u = self._url("/containers/{0}/attach".format(container))
@ -151,7 +154,7 @@ class Client(requests.Session):
# eventually block # eventually block
return res.raw._fp.fp._sock return res.raw._fp.fp._sock
def attach_websocket(self, container, params=None): def _attach_websocket(self, container, params=None):
url = self._url("/containers/{0}/attach/ws".format(container)) url = self._url("/containers/{0}/attach/ws".format(container))
req = requests.Request("POST", url, params=self._attach_params(params)) req = requests.Request("POST", url, params=self._attach_params(params))
full_url = req.prepare().url full_url = req.prepare().url