children of this class.
@ivar dry_run: Whether the LU should be run in dry-run mode, i.e. just
the check steps
+ @ivar priority: Opcode priority for queue
"""
OP_ID = "OP_ABSTRACT"
- __slots__ = ["dry_run", "debug_level"]
+ __slots__ = ["dry_run", "debug_level", "priority"]
def __getstate__(self):
"""Specialized getstate for opcodes.
field_name = getattr(self, "OP_DSC_FIELD", None)
if field_name:
field_value = getattr(self, field_name, None)
+ if isinstance(field_value, (list, tuple)):
+ field_value = ",".join(str(i) for i in field_value)
txt = "%s(%s)" % (txt, field_value)
return txt
"""
OP_ID = "OP_NODE_ADD"
OP_DSC_FIELD = "node_name"
- __slots__ = ["node_name", "primary_ip", "secondary_ip", "readd"]
+ __slots__ = ["node_name", "primary_ip", "secondary_ip", "readd", "nodegroup"]
class OpQueryNodes(OpCode):
__slots__ = [
"node_name",
"mode",
+ "live",
]
"source_handshake",
"source_x509_ca",
"source_instance_name",
- "dry_run",
]
"""Rename an instance."""
OP_ID = "OP_INSTANCE_RENAME"
__slots__ = [
- "instance_name", "ignore_ip", "new_name", "check_name",
+ "instance_name", "ip_check", "new_name", "name_check",
]
"""
OP_ID = "OP_INSTANCE_MIGRATE"
OP_DSC_FIELD = "instance_name"
- __slots__ = ["instance_name", "mode", "cleanup"]
+ __slots__ = ["instance_name", "mode", "cleanup", "live"]
class OpMoveInstance(OpCode):
]
+class OpTestDummy(OpCode):
+ """Utility opcode used by unittests.
+
+ """
+ OP_ID = "OP_TEST_DUMMY"
+ __slots__ = [
+ "result",
+ "messages",
+ "fail",
+ ]
+
+
OP_MAPPING = dict([(v.OP_ID, v) for v in globals().values()
if (isinstance(v, type) and issubclass(v, OpCode) and
hasattr(v, "OP_ID"))])