Synnefo » snf-ganeti

    """

    assert "__slots__" not in attrs, \

      "Class '%s' defines __slots__ when it should use OP_PARAMS" % name

    # Always set OP_PARAMS to avoid duplicates in BaseOpCode.GetAllParams

    params = attrs.setdefault("OP_PARAMS", [])

  field handling.

  """

  __metaclass__ = _AutoOpParamSlots

  def __init__(self, **kwargs):

    """Constructor for BaseOpCode.

  @ivar priority: Opcode priority for queue

  """

  WITH_LU = True

  OP_PARAMS = [

    ("dry_run", None, ht.TMaybeBool),

  after the cluster has been initialized.

  """

class OpClusterDestroy(OpCode):

  lost after the execution of this opcode.

  """

class OpClusterQuery(OpCode):

  """Query cluster information."""

class OpClusterVerify(OpCode):

                     only L{constants.VERIFY_NPLUSONE_MEM} can be passed

  """

  OP_PARAMS = [

    ("skip_checks", ht.EmptyList,

     ht.TListOf(ht.TElemOf(constants.VERIFY_OPTIONAL_CHECKS))),

  consideration. This might need to be revisited in the future.

  """

class OpClusterRepairDiskSizes(OpCode):

  @ivar instances: the list of instances to check, or empty for all instances

  """

  OP_PARAMS = [

    ("instances", ht.EmptyList, ht.TListOf(ht.TNonEmptyString)),

    ]

class OpClusterConfigQuery(OpCode):

  """Query cluster configuration values."""

  OP_PARAMS = [

    _POutputFields

    ]

              address.

  """

  OP_DSC_FIELD = "name"

  OP_PARAMS = [

    ("name", ht.NoDefault, ht.TNonEmptyString),

  @ivar vg_name: The new volume group name or None to disable LVM usage.

  """

  OP_PARAMS = [

    ("vg_name", None, ht.TMaybeString),

    ("enabled_hypervisors", None,

  """Force a full push of the cluster configuration.

  """

class OpQuery(OpCode):

  @ivar filter: Query filter

  """

  OP_PARAMS = [

    ("what", ht.NoDefault, ht.TElemOf(constants.QR_OP_QUERY)),

    ("fields", ht.NoDefault, ht.TListOf(ht.TNonEmptyString)),

  @ivar fields: List of fields to retrieve

  """

  OP_PARAMS = [

    ("what", ht.NoDefault, ht.TElemOf(constants.QR_OP_QUERY)),

    ("fields", None, ht.TOr(ht.TNone, ht.TListOf(ht.TNonEmptyString))),

class OpOobCommand(OpCode):

  """Interact with OOB."""

  OP_PARAMS = [

    _PNodeName,

    ("command", None, ht.TElemOf(constants.OOB_COMMANDS)),

                   instances on it, the operation will fail.

  """

  OP_DSC_FIELD = "node_name"

  OP_PARAMS = [

    _PNodeName,

  @ivar master_capable: The master_capable node attribute

  """

  OP_DSC_FIELD = "node_name"

  OP_PARAMS = [

    _PNodeName,

class OpNodeQuery(OpCode):

  """Compute the list of nodes."""

  OP_PARAMS = [

    _POutputFields,

    ("names", ht.EmptyList, ht.TListOf(ht.TNonEmptyString)),

class OpNodeQueryvols(OpCode):

  """Get list of volumes on node."""

  OP_PARAMS = [

    _POutputFields,

    ("nodes", ht.EmptyList, ht.TListOf(ht.TNonEmptyString)),

class OpNodeQueryStorage(OpCode):

  """Get information on storage for node(s)."""

  OP_PARAMS = [

    _POutputFields,

    _PStorageType,

class OpNodeModifyStorage(OpCode):

  """Modifies the properies of a storage unit"""

  OP_PARAMS = [

    _PNodeName,

    _PStorageType,

class OpRepairNodeStorage(OpCode):

  """Repairs the volume group on a node."""

  OP_DSC_FIELD = "node_name"

  OP_PARAMS = [

    _PNodeName,

class OpNodeSetParams(OpCode):

  """Change the parameters of a node."""

  OP_DSC_FIELD = "node_name"

  OP_PARAMS = [

    _PNodeName,

class OpNodePowercycle(OpCode):

  """Tries to powercycle a node."""

  OP_DSC_FIELD = "node_name"

  OP_PARAMS = [

    _PNodeName,

class OpNodeMigrate(OpCode):

  """Migrate all instances from a node."""

  OP_DSC_FIELD = "node_name"

  OP_PARAMS = [

    _PNodeName,

class OpNodeEvacStrategy(OpCode):

  """Compute the evacuation strategy for a list of nodes."""

  OP_DSC_FIELD = "nodes"

  OP_PARAMS = [

    ("nodes", ht.NoDefault, ht.TListOf(ht.TNonEmptyString)),

    (remote import only)

  """

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpInstanceReinstall(OpCode):

  """Reinstall an instance's OS."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpInstanceRemove(OpCode):

  """Remove an instance."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpInstanceRename(OpCode):

  """Rename an instance."""

  OP_PARAMS = [

    _PInstanceName,

    ("new_name", ht.NoDefault, ht.TNonEmptyString),

class OpInstanceStartup(OpCode):

  """Startup an instance."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpInstanceShutdown(OpCode):

  """Shutdown an instance."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpInstanceReboot(OpCode):

  """Reboot an instance."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpInstanceReplaceDisks(OpCode):

  """Replace the disks of an instance."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpInstanceFailover(OpCode):

  """Failover an instance."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

  @ivar mode: the migration mode (live, non-live or None for auto)

  """

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

  @ivar target_node: the destination node

  """

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpInstanceConsole(OpCode):

  """Connect to an instance's console."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName

class OpInstanceActivateDisks(OpCode):

  """Activate an instance's disks."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpInstanceDeactivateDisks(OpCode):

  """Deactivate an instance's disks."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName

class OpInstanceRecreateDisks(OpCode):

  """Deactivate an instance's disks."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpInstanceQuery(OpCode):

  """Compute the list of instances."""

  OP_PARAMS = [

    _POutputFields,

    ("names", ht.EmptyList, ht.TListOf(ht.TNonEmptyString)),

class OpInstanceQueryData(OpCode):

  """Compute the run-time status of instances."""

  OP_PARAMS = [

    ("instances", ht.EmptyList, ht.TListOf(ht.TNonEmptyString)),

    ("static", False, ht.TBool),

class OpInstanceSetParams(OpCode):

  """Change the parameters of an instance."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpInstanceGrowDisk(OpCode):

  """Grow a disk of an instance."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpGroupAdd(OpCode):

  """Add a node group to the cluster."""

  OP_DSC_FIELD = "group_name"

  OP_PARAMS = [

    _PGroupName,

class OpGroupAssignNodes(OpCode):

  """Assign nodes to a node group."""

  OP_DSC_FIELD = "group_name"

  OP_PARAMS = [

    _PGroupName,

class OpGroupQuery(OpCode):

  """Compute the list of node groups."""

  OP_PARAMS = [

    _POutputFields,

    ("names", ht.EmptyList, ht.TListOf(ht.TNonEmptyString)),

class OpGroupSetParams(OpCode):

  """Change the parameters of a node group."""

  OP_DSC_FIELD = "group_name"

  OP_PARAMS = [

    _PGroupName,

class OpGroupRemove(OpCode):

  """Remove a node group from the cluster."""

  OP_DSC_FIELD = "group_name"

  OP_PARAMS = [

    _PGroupName,

class OpGroupRename(OpCode):

  """Rename a node group in the cluster."""

  OP_DSC_FIELD = "old_name"

  OP_PARAMS = [

    ("old_name", ht.NoDefault, ht.TNonEmptyString),

# OS opcodes

class OpOsDiagnose(OpCode):

  """Compute the list of guest operating systems."""

  OP_PARAMS = [

    _POutputFields,

    ("names", ht.EmptyList, ht.TListOf(ht.TNonEmptyString)),

# Exports opcodes

class OpBackupQuery(OpCode):

  """Compute the list of exported images."""

  OP_PARAMS = [

    ("nodes", ht.EmptyList, ht.TListOf(ht.TNonEmptyString)),

    ("use_locking", False, ht.TBool),

  @ivar mode: Export mode (one of L{constants.EXPORT_MODES})

  """

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

                             only)

  """

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

class OpBackupRemove(OpCode):

  """Remove an instance's export."""

  OP_DSC_FIELD = "instance_name"

  OP_PARAMS = [

    _PInstanceName,

# Tags opcodes

class OpTagsGet(OpCode):

  """Returns the tags of the given object."""

  OP_DSC_FIELD = "name"

  OP_PARAMS = [

    _PTagKind,

class OpTagsSearch(OpCode):

  """Searches the tags in the cluster for a given pattern."""

  OP_DSC_FIELD = "pattern"

  OP_PARAMS = [

    ("pattern", ht.NoDefault, ht.TNonEmptyString),

class OpTagsSet(OpCode):

  """Add a list of tags on a given object."""

  OP_PARAMS = [

    _PTagKind,

    _PTags,

class OpTagsDel(OpCode):

  """Remove a list of tags from a given object."""

  OP_PARAMS = [

    _PTagKind,

    _PTags,

  generator. The case of duration == 0 will not be treated specially.

  """

  OP_DSC_FIELD = "duration"

  OP_PARAMS = [

    ("duration", ht.NoDefault, ht.TFloat),

      return the allocator output (direction 'out')

  """

  OP_DSC_FIELD = "allocator"

  OP_PARAMS = [

    ("direction", ht.NoDefault,

  """Utility opcode to test some aspects of the job queue.

  """

  OP_PARAMS = [

    ("notify_waitlock", False, ht.TBool),

    ("notify_exec", False, ht.TBool),

  """Utility opcode used by unittests.

  """

  OP_PARAMS = [

    ("result", ht.NoDefault, ht.NoType),

    ("messages", ht.NoDefault, ht.NoType),