X-Git-Url: https://code.grnet.gr/git/ganeti-local/blobdiff_plain/a0c9f0106fd2c671e982dc9300c438b4fa5d54bc..468c5f773ae4d7b7e10e575afe71fbdedfd988ad:/lib/opcodes.py diff --git a/lib/opcodes.py b/lib/opcodes.py index 094d085..0c8ad18 100644 --- a/lib/opcodes.py +++ b/lib/opcodes.py @@ -73,51 +73,6 @@ class BaseJO(object): setattr(self, name, state[name]) -class Job(BaseJO): - """Job definition structure - - The Job definitions has two sets of parameters: - - the parameters of the job itself (all filled by server): - - job_id, - - status: pending, running, successfull, failed, aborted - - opcode parameters: - - op_list, list of opcodes, clients creates this - - op_status, status for each opcode, server fills in - - op_result, result for each opcode, server fills in - - """ - STATUS_PENDING = 1 - STATUS_RUNNING = 2 - STATUS_SUCCESS = 3 - STATUS_FAIL = 4 - STATUS_ABORT = 5 - - __slots__ = [ - "job_id", - "status", - "op_list", - "op_status", - "op_result", - ] - - def __getstate__(self): - """Specialized getstate for jobs - - """ - data = BaseJO.__getstate__(self) - if "op_list" in data: - data["op_list"] = [op.__getstate__() for op in data["op_list"]] - return data - - def __setstate__(self, state): - """Specialized setstate for jobs - - """ - BaseJO.__setstate__(self, state) - if "op_list" in state: - self.op_list = [OpCode.LoadOpCode(op) for op in state["op_list"]] - - class OpCode(BaseJO): """Abstract OpCode""" OP_ID = "OP_ABSTRACT" @@ -171,18 +126,6 @@ class OpQueryClusterInfo(OpCode): __slots__ = [] -class OpClusterCopyFile(OpCode): - """Copy a file to multiple nodes.""" - OP_ID = "OP_CLUSTER_COPYFILE" - __slots__ = ["nodes", "filename"] - - -class OpRunClusterCommand(OpCode): - """Run a command on multiple nodes.""" - OP_ID = "OP_CLUSTER_RUNCOMMAND" - __slots__ = ["nodes", "command"] - - class OpVerifyCluster(OpCode): """Verify the cluster state.""" OP_ID = "OP_CLUSTER_VERIFY" @@ -370,6 +313,12 @@ class OpSetInstanceParams(OpCode): ] +class OpGrowDisk(OpCode): + """Grow a disk of an instance.""" + OP_ID = "OP_INSTANCE_GROW_DISK" + __slots__ = ["instance_name", "disk", "amount"] + + # OS opcodes class OpDiagnoseOS(OpCode): """Compute the list of guest operating systems."""