Synnefo » snf-ganeti

                    "hvparams": {},

                    "file_storage_dir": None,

                    "force_variant": False,

  def _PopulateWithDefaults(spec):

    """Returns a new hash combined with default values."""

  def _Validate(spec):

    """Validate the instance specs."""

    # Validate fields required under any circumstances

      if required_field not in spec:

        raise errors.OpPrereqError('Required field "%s" is missing.' %

                                   required_field, errors.ECODE_INVAL)

    # Validate special fields

                                   errors.ECODE_INVAL)

                                 errors.ECODE_INVAL)

                                 errors.ECODE_INVAL)

  json_filename = args[0]

    specs = _PopulateWithDefaults(specs)

    _Validate(specs)

    disks = []

      try:

        size = utils.ParseUnit(elem)

      except (TypeError, ValueError), err:

                                   (elem, name, err), errors.ECODE_INVAL)

      disks.append({"size": size})

    utils.ForceDictType(hvparams, constants.HVS_PARAMETER_TYPES)

    tmp_nics = []

          tmp_nics.append({})

        tmp_nics[0][field] = specs[field]

      raise errors.OpPrereqError("'nics' list incompatible with using"

                                 " individual nic fields as well",

                                 errors.ECODE_INVAL)

    elif not tmp_nics:

      tmp_nics = [{}]

    op = opcodes.OpInstanceCreate(instance_name=name,

                                  disks=disks,

                                  mode=constants.INSTANCE_CREATE,

                                  force_variant=specs["force_variant"],

                                  nics=tmp_nics,

                                  wait_for_sync=True,

                                  hypervisor=hypervisor,

                                  hvparams=hvparams,

    jex.QueueJob(name, op)

  # we never want to wait, just show the submitted job IDs

        choices.append(("%s" % number, entry, entry))

        number += 1

    selected = AskUser("Enter OS template number (or x to abort):",

                       choices)

      ToStderr("User aborted reinstall, exiting")

      return 1

      _FormatList(buf, _FormatBlockDevInfo(idx, True, device,

                  opts.roman_integers), 2)

  return retcode

    except (TypeError, ValueError):

      pass

    if disk_op == constants.DDM_ADD:

        raise errors.OpPrereqError("Missing required parameter 'size'",

                                   errors.ECODE_INVAL)

  if (opts.disk_template and

      opts.disk_template in constants.DTS_INT_MIRROR and

  ]

commands = {

    AddInstance, [ArgHost(min=1, max=1)], COMMON_CREATE_OPTS + add_opts,

    "[...] -t disk-type -n node[:secondary-node] -o os-type <name>",

    "Creates and adds a new instance to the cluster"),

    BatchCreate, [ArgFile(min=1, max=1)], [DRY_RUN_OPT, PRIORITY_OPT],

    "<instances.json>",

    "Create a bunch of instances based on specs in the file."),

    ConnectToInstanceConsole, ARGS_ONE_INSTANCE,

    [SHOWCMD_OPT, PRIORITY_OPT],

    "[--show-cmd] <instance>", "Opens a console on the specified instance"),

    FailoverInstance, ARGS_ONE_INSTANCE,

    [FORCE_OPT, IGNORE_CONSIST_OPT, SUBMIT_OPT, SHUTDOWN_TIMEOUT_OPT,

     DRY_RUN_OPT, PRIORITY_OPT, DST_NODE_OPT, IALLOCATOR_OPT],

    "[-f] <instance>", "Stops the instance and starts it on the backup node,"

    " using the remote mirror (only for mirrored instances)"),

    MigrateInstance, ARGS_ONE_INSTANCE,

    [FORCE_OPT, NONLIVE_OPT, MIGRATION_MODE_OPT, CLEANUP_OPT, DRY_RUN_OPT,

     PRIORITY_OPT, DST_NODE_OPT, IALLOCATOR_OPT, ALLOW_FAILOVER_OPT],

    "[-f] <instance>", "Migrate instance to its secondary node"

    " (only for mirrored instances)"),

    MoveInstance, ARGS_ONE_INSTANCE,

    [FORCE_OPT, SUBMIT_OPT, SINGLE_NODE_OPT, SHUTDOWN_TIMEOUT_OPT,

     DRY_RUN_OPT, PRIORITY_OPT, IGNORE_CONSIST_OPT],

    "[-f] <instance>", "Move instance to an arbitrary node"

    " (only for instances of type file and lv)"),

    ShowInstanceConfig, ARGS_MANY_INSTANCES,

    [STATIC_OPT, ALL_OPT, ROMAN_OPT, PRIORITY_OPT],

    "[-s] {--all | <instance>...}",

    "Show information on the specified instance(s)"),

    ListInstances, ARGS_MANY_INSTANCES,

    [NOHDR_OPT, SEP_OPT, USEUNITS_OPT, FIELDS_OPT, VERBOSE_OPT,

     FORCE_FILTER_OPT],

    [NOHDR_OPT, SEP_OPT],

    "[fields...]",

    "Lists all available fields for instances"),

    ReinstallInstance, [ArgInstance()],

    [FORCE_OPT, OS_OPT, FORCE_VARIANT_OPT, m_force_multi, m_node_opt,

     m_pri_node_opt, m_sec_node_opt, m_clust_opt, m_inst_opt, m_node_tags_opt,

     m_pri_node_tags_opt, m_sec_node_tags_opt, m_inst_tags_opt, SELECT_OS_OPT,

     SUBMIT_OPT, DRY_RUN_OPT, PRIORITY_OPT, OSPARAMS_OPT],

    "[-f] <instance>", "Reinstall a stopped instance"),

    RemoveInstance, ARGS_ONE_INSTANCE,

    [FORCE_OPT, SHUTDOWN_TIMEOUT_OPT, IGNORE_FAILURES_OPT, SUBMIT_OPT,

     DRY_RUN_OPT, PRIORITY_OPT],

    "[-f] <instance>", "Shuts down the instance and removes it"),

    RenameInstance,

    [ArgInstance(min=1, max=1), ArgHost(min=1, max=1)],

    [NOIPCHECK_OPT, NONAMECHECK_OPT, SUBMIT_OPT, DRY_RUN_OPT, PRIORITY_OPT],

    "<instance> <new_name>", "Rename the instance"),

    ReplaceDisks, ARGS_ONE_INSTANCE,

    [AUTO_REPLACE_OPT, DISKIDX_OPT, IALLOCATOR_OPT, EARLY_RELEASE_OPT,

     NEW_SECONDARY_OPT, ON_PRIMARY_OPT, ON_SECONDARY_OPT, SUBMIT_OPT,

     DRY_RUN_OPT, PRIORITY_OPT],

    "[-s|-p|-n NODE|-I NAME] <instance>",

    "Replaces all disks for the instance"),

    SetInstanceParams, ARGS_ONE_INSTANCE,

    [BACKEND_OPT, DISK_OPT, FORCE_OPT, HVOPTS_OPT, NET_OPT, SUBMIT_OPT,

     DISK_TEMPLATE_OPT, SINGLE_NODE_OPT, OS_OPT, FORCE_VARIANT_OPT,

     OSPARAMS_OPT, DRY_RUN_OPT, PRIORITY_OPT, NWSYNC_OPT],

    "<instance>", "Alters the parameters of an instance"),

    GenericManyOps("shutdown", _ShutdownInstance), [ArgInstance()],

    [m_node_opt, m_pri_node_opt, m_sec_node_opt, m_clust_opt,

     m_node_tags_opt, m_pri_node_tags_opt, m_sec_node_tags_opt,

     m_inst_tags_opt, m_inst_opt, m_force_multi, TIMEOUT_OPT, SUBMIT_OPT,

     DRY_RUN_OPT, PRIORITY_OPT, IGNORE_OFFLINE_OPT, NO_REMEMBER_OPT],

    "<instance>", "Stops an instance"),

    GenericManyOps("startup", _StartupInstance), [ArgInstance()],

    [FORCE_OPT, m_force_multi, m_node_opt, m_pri_node_opt, m_sec_node_opt,

     m_node_tags_opt, m_pri_node_tags_opt, m_sec_node_tags_opt,

     BACKEND_OPT, DRY_RUN_OPT, PRIORITY_OPT, IGNORE_OFFLINE_OPT,

     NO_REMEMBER_OPT, STARTUP_PAUSED_OPT],

    "<instance>", "Starts an instance"),

    GenericManyOps("reboot", _RebootInstance), [ArgInstance()],

    [m_force_multi, REBOOT_TYPE_OPT, IGNORE_SECONDARIES_OPT, m_node_opt,

     m_pri_node_opt, m_sec_node_opt, m_clust_opt, m_inst_opt, SUBMIT_OPT,

     m_node_tags_opt, m_pri_node_tags_opt, m_sec_node_tags_opt,

     m_inst_tags_opt, SHUTDOWN_TIMEOUT_OPT, DRY_RUN_OPT, PRIORITY_OPT],

    "<instance>", "Reboots an instance"),

    ActivateDisks, ARGS_ONE_INSTANCE,

    [SUBMIT_OPT, IGNORE_SIZE_OPT, PRIORITY_OPT],

    "<instance>", "Activate an instance's disks"),

    DeactivateDisks, ARGS_ONE_INSTANCE,

    [FORCE_OPT, SUBMIT_OPT, DRY_RUN_OPT, PRIORITY_OPT],

    "[-f] <instance>", "Deactivate an instance's disks"),

    RecreateDisks, ARGS_ONE_INSTANCE,

    [SUBMIT_OPT, DISKIDX_OPT, NODE_PLACEMENT_OPT, DRY_RUN_OPT, PRIORITY_OPT],

    "<instance>", "Recreate an instance's disks"),

    GrowDisk,

    [ArgInstance(min=1, max=1), ArgUnknown(min=1, max=1),

     ArgUnknown(min=1, max=1)],

    [SUBMIT_OPT, NWSYNC_OPT, DRY_RUN_OPT, PRIORITY_OPT],

    "<instance> <disk> <size>", "Grow an instance's disk"),

    ListTags, ARGS_ONE_INSTANCE, [PRIORITY_OPT],

    "<instance_name>", "List the tags of the given instance"),

    AddTags, [ArgInstance(min=1, max=1), ArgUnknown()],

    [TAG_SRC_OPT, PRIORITY_OPT],

    "<instance_name> tag...", "Add tags to the given instance"),

    RemoveTags, [ArgInstance(min=1, max=1), ArgUnknown()],

    [TAG_SRC_OPT, PRIORITY_OPT],

    "<instance_name> tag...", "Remove tags from given instance"),

#: dictionary with aliases for commands

aliases = {

  }