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
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
# Copyright 2012 OpenStack Foundation
# All Rights Reserved.
#
# 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.
"""
Common instance status code used across Trove API.
"""
class InstanceTask(object):
"""
Stores the different kind of tasks being performed by an instance.
"""
# TODO(tim.simpson): Figure out someway to migrate this to the TaskManager
# once that revs up.
_lookup = {}
def __init__(self, code, action, db_text, is_error=False):
self._code = int(code)
self._action = action
self._db_text = db_text
self._is_error = is_error
InstanceTask._lookup[self._code] = self
@property
def action(self):
return self._action
@property
def code(self):
return self._code
@property
def db_text(self):
return self._db_text
@property
def is_error(self):
return self._is_error
def __eq__(self, other):
if not isinstance(other, InstanceTask):
return False
return self._db_text == other._db_text
@classmethod
def from_code(cls, code):
if code not in cls._lookup:
return None
return cls._lookup[code]
def __str__(self):
return "(%d %s %s)" % (self._code, self._action, self._db_text)
def __repr__(self):
return "InstanceTask.%s (%s)" % (self._action, self._db_text)
class InstanceTasks(object):
NONE = InstanceTask(0x01, 'NONE', 'No tasks for the instance.')
DELETING = InstanceTask(0x02, 'DELETING', 'Deleting the instance.')
REBOOTING = InstanceTask(0x03, 'REBOOTING', 'Rebooting the instance.')
RESIZING = InstanceTask(0x04, 'RESIZING', 'Resizing the instance.')
BUILDING = InstanceTask(0x05, 'BUILDING', 'The instance is building.')
MIGRATING = InstanceTask(0x06, 'MIGRATING', 'Migrating the instance.')
RESTART_REQUIRED = InstanceTask(0x07, 'RESTART_REQUIRED',
'Instance requires a restart.')
PROMOTING = InstanceTask(0x08, 'PROMOTING',
'Promoting the instance to replica source.')
EJECTING = InstanceTask(0x09, 'EJECTING',
'Ejecting the replica source.')
LOGGING = InstanceTask(0x0a, 'LOGGING', 'Transferring guest logs.')
DETACHING = InstanceTask(0x0b, 'DETACHING',
'Detaching the instance from replica source.')
UPDATING = InstanceTask(0x0c, 'UPDATING', 'Updating the instance.')
BUILDING_ERROR_DNS = InstanceTask(0x50, 'BUILDING', 'Build error: DNS.',
is_error=True)
BUILDING_ERROR_SERVER = InstanceTask(0x51, 'BUILDING',
'Build error: Server.',
is_error=True)
BUILDING_ERROR_VOLUME = InstanceTask(0x52, 'BUILDING',
'Build error: Volume.',
is_error=True)
BUILDING_ERROR_SEC_GROUP = InstanceTask(0x53, 'BUILDING',
'Build error: Secgroup '
'or rule.',
is_error=True)
BUILDING_ERROR_REPLICA = InstanceTask(0x54, 'BUILDING',
'Build error: Replica.',
is_error=True)
PROMOTION_ERROR = InstanceTask(0x55, 'PROMOTING',
'Replica Promotion Error.',
is_error=True)
EJECTION_ERROR = InstanceTask(0x56, 'EJECTING',
'Replica Source Ejection Error.',
is_error=True)
GROWING_ERROR = InstanceTask(0x57, 'GROWING',
'Growing Cluster Error.',
is_error=True)
SHRINKING_ERROR = InstanceTask(0x58, 'SHRINKING',
'Shrinking Cluster Error.',
is_error=True)
UPGRADING = InstanceTask(0x59, 'UPGRADING', 'Upgrading the instance.')
UPGRADING_ERROR = InstanceTask(0x5a, 'UPGRADING',
'Upgrading Cluster Error.',
is_error=True)
BUILDING_ERROR_TIMEOUT_GA = InstanceTask(0x5b, 'ERROR',
'Build error: '
'guestagent timeout.',
is_error=True)
BUILDING_ERROR_PORT = InstanceTask(0x5c, 'BUILDING',
'Build error: Port.',
is_error=True)
UPDATING_ERROR_ACCESS = InstanceTask(0x5d, 'UPDATING',
'Update error: Access.',
is_error=True)
# Dissuade further additions at run-time.
InstanceTask.__init__ = None
|
