|
1 | 1 | import json
|
2 | 2 |
|
3 | 3 | from ..errors import InvalidVersion
|
4 |
| -from ..utils import check_resource, minimum_version, normalize_links |
| 4 | +from ..utils import check_resource, minimum_version |
5 | 5 | from ..utils import version_lt
|
6 | 6 |
|
7 | 7 |
|
@@ -63,26 +63,12 @@ def connect_container_to_network(self, container, net_id,
|
63 | 63 | aliases=None, links=None):
|
64 | 64 | data = {
|
65 | 65 | "Container": container,
|
66 |
| - "EndpointConfig": { |
67 |
| - "Aliases": aliases, |
68 |
| - "Links": normalize_links(links) if links else None, |
69 |
| - }, |
| 66 | + "EndpointConfig": self.create_endpoint_config( |
| 67 | + aliases=aliases, links=links, ipv4_address=ipv4_address, |
| 68 | + ipv6_address=ipv6_address |
| 69 | + ), |
70 | 70 | }
|
71 | 71 |
|
72 |
| - # IPv4 or IPv6 or neither: |
73 |
| - if ipv4_address or ipv6_address: |
74 |
| - if version_lt(self._version, '1.22'): |
75 |
| - raise InvalidVersion('IP address assignment is not ' |
76 |
| - 'supported in API version < 1.22') |
77 |
| - |
78 |
| - data['EndpointConfig']['IPAMConfig'] = dict() |
79 |
| - if ipv4_address: |
80 |
| - data['EndpointConfig']['IPAMConfig']['IPv4Address'] = \ |
81 |
| - ipv4_address |
82 |
| - if ipv6_address: |
83 |
| - data['EndpointConfig']['IPAMConfig']['IPv6Address'] = \ |
84 |
| - ipv6_address |
85 |
| - |
86 | 72 | url = self._url("/networks/{0}/connect", net_id)
|
87 | 73 | res = self._post_json(url, data=data)
|
88 | 74 | self._raise_for_status(res)
|
|
0 commit comments