1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
# 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.
"""Attachment interface."""
from cinderclient import api_versions
from cinderclient import base
class VolumeAttachment(base.Resource):
"""An attachment is a connected volume."""
def __repr__(self):
"""Obj to Str method."""
return "<Attachment: %s>" % self.id
class VolumeAttachmentManager(base.ManagerWithFind):
resource_class = VolumeAttachment
@api_versions.wraps('3.27')
def create(self, volume_id, connector, instance_id=None, mode='null'):
"""Create a attachment for specified volume."""
body = {'attachment': {'volume_uuid': volume_id,
'connector': connector}}
if instance_id:
body['attachment']['instance_uuid'] = instance_id
if self.api_version >= api_versions.APIVersion("3.54"):
if mode and mode != 'null':
body['attachment']['mode'] = mode
retval = self._create('/attachments', body, 'attachment')
return retval.to_dict()
@api_versions.wraps('3.27')
def delete(self, attachment):
"""Delete an attachment by ID."""
return self._delete("/attachments/%s" % base.getid(attachment))
@api_versions.wraps('3.27')
def list(self, detailed=False, search_opts=None, marker=None, limit=None,
sort=None):
"""List all attachments."""
resource_type = "attachments"
url = self._build_list_url(resource_type,
detailed=detailed,
search_opts=search_opts,
marker=marker,
limit=limit,
sort=sort)
return self._list(url, resource_type, limit=limit)
@api_versions.wraps('3.27')
def show(self, id):
"""Attachment show.
:param id: Attachment ID.
"""
url = '/attachments/%s' % id
resp, body = self.api.client.get(url)
return self.resource_class(self, body['attachment'], loaded=True,
resp=resp)
@api_versions.wraps('3.27')
def update(self, id, connector):
"""Attachment update."""
body = {'attachment': {'connector': connector}}
resp = self._update('/attachments/%s' % id, body)
# NOTE(jdg): This kinda sucks,
# create returns a dict, but update returns an object :(
return self.resource_class(self, resp['attachment'], loaded=True,
resp=resp)
@api_versions.wraps('3.44')
def complete(self, attachment):
"""Mark the attachment as completed."""
resp, body = self._action_return_resp_and_body('os-complete',
attachment,
None)
return resp
def _action_return_resp_and_body(self, action, attachment, info=None,
**kwargs):
"""Perform a attachments "action" and return response headers and body.
"""
body = {action: info}
self.run_hooks('modify_body_for_action', body, **kwargs)
url = '/attachments/%s/action' % base.getid(attachment)
return self.api.client.post(url, body=body)
|
