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
98
99
100
101
102
103
104
105
106
107
108
109
110
|
# 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.
import warnings
from openstack.common import metadata
from openstack import exceptions
from openstack import format
from openstack import resource
from openstack import utils
from openstack import warnings as os_warnings
class Snapshot(resource.Resource, metadata.MetadataMixin):
resource_key = "snapshot"
resources_key = "snapshots"
base_path = "/snapshots"
_query_mapping = resource.QueryParameters(
'name', 'status', 'volume_id', all_projects='all_tenants'
)
# capabilities
allow_fetch = True
allow_create = True
allow_delete = True
allow_commit = True
allow_list = True
# Properties
#: The timestamp of this snapshot creation.
created_at = resource.Body("created_at")
#: Description of snapshot. Default is None.
description = resource.Body("description")
#: Indicate whether to create snapshot, even if the volume is attached.
#: Default is ``False``. *Type: bool*
is_forced = resource.Body("force", type=format.BoolStr)
#: The size of the volume, in GBs.
size = resource.Body("size", type=int)
#: The current status of this snapshot. Potential values are creating,
#: available, deleting, error, and error_deleting.
status = resource.Body("status")
#: The date and time when the resource was updated.
updated_at = resource.Body("updated_at")
#: The ID of the volume this snapshot was taken of.
volume_id = resource.Body("volume_id")
def _action(self, session, body):
"""Preform backup actions given the message body."""
url = utils.urljoin(self.base_path, self.id, 'action')
resp = session.post(url, json=body)
exceptions.raise_from_response(resp)
return resp
def reset_status(self, session, status):
"""Reset the status of the snapshot."""
body = {'os-reset_status': {'status': status}}
self._action(session, body)
def reset(self, session, status):
warnings.warn(
"reset is a deprecated alias for reset_status and will be "
"removed in a future release.",
os_warnings.RemovedInSDK60Warning,
)
self.reset_status(session, status)
@classmethod
def manage(
cls,
session,
volume_id,
ref,
name=None,
description=None,
metadata=None,
):
"""Manage a snapshot under block storage provisioning."""
url = '/os-snapshot-manage'
body = {
'snapshot': {
'volume_id': volume_id,
'ref': ref,
'name': name,
'description': description,
'metadata': metadata,
}
}
resp = session.post(url, json=body)
exceptions.raise_from_response(resp)
snapshot = Snapshot()
snapshot._translate_response(resp)
return snapshot
def unmanage(self, session):
"""Unmanage a snapshot from block storage provisioning."""
body = {'os-unmanage': None}
self._action(session, body)
SnapshotDetail = Snapshot
|
