|
26 | 26 | from . import constants
|
27 | 27 | from . import errors
|
28 | 28 | from .auth import auth
|
29 |
| -from .unixconn import unixconn |
| 29 | +from .ssladapter import ssladapter |
| 30 | +from .tls import TLSConfig |
| 31 | +from .transport import UnixAdapter |
| 32 | +from .utils import utils, check_resource, update_headers, kwargs_from_env |
30 | 33 | try:
|
31 |
| - from .npipeconn import npipeconn |
| 34 | + from .transport import NpipeAdapter |
32 | 35 | except ImportError:
|
33 | 36 | pass
|
34 |
| -from .ssladapter import ssladapter |
35 |
| -from .utils import utils, check_resource, update_headers, kwargs_from_env |
36 |
| -from .tls import TLSConfig |
37 | 37 |
|
38 | 38 |
|
39 | 39 | def from_env(**kwargs):
|
@@ -65,15 +65,20 @@ def __init__(self, base_url=None, version=None,
|
65 | 65 |
|
66 | 66 | base_url = utils.parse_host(base_url, sys.platform, tls=bool(tls))
|
67 | 67 | if base_url.startswith('http+unix://'):
|
68 |
| - self._custom_adapter = unixconn.UnixAdapter(base_url, timeout) |
| 68 | + self._custom_adapter = UnixAdapter(base_url, timeout) |
69 | 69 | self.mount('http+docker://', self._custom_adapter)
|
70 | 70 | self.base_url = 'http+docker://localunixsocket'
|
71 | 71 | elif base_url.startswith('npipe://'):
|
72 | 72 | if not constants.IS_WINDOWS_PLATFORM:
|
73 | 73 | raise errors.DockerException(
|
74 | 74 | 'The npipe:// protocol is only supported on Windows'
|
75 | 75 | )
|
76 |
| - self._custom_adapter = npipeconn.NpipeAdapter(base_url, timeout) |
| 76 | + try: |
| 77 | + self._custom_adapter = NpipeAdapter(base_url, timeout) |
| 78 | + except NameError: |
| 79 | + raise errors.DockerException( |
| 80 | + 'Install pypiwin32 package to enable npipe:// support' |
| 81 | + ) |
77 | 82 | self.mount('http+docker://', self._custom_adapter)
|
78 | 83 | self.base_url = 'http+docker://localnpipe'
|
79 | 84 | else:
|
|
0 commit comments