Synnefo » snf-ganeti » ganeti-local

  for (_, _, optdef, _, _) in commands.itervalues():

    if help_option not in optdef:

      optdef.append(help_option)

  # Use aliases

  aliases = getattr(module, "aliases", {})

    cmd = aliases[cmd]

  func, args_def, parser_opts, usage, description = commands[cmd]

                        description=description,

                        formatter=TitledHelpFormatter(),

                        usage="%%prog %s %s" % (cmd, usage))

# this is defined separately due to readability only

import_opts = [

  NODE_PLACEMENT_OPT,

  BACKEND_OPT,

  DISK_TEMPLATE_OPT,

commands = {

  'list': (

    PrintExportList, ARGS_NONE,

    "", "Lists instance exports available in the ganeti cluster"),

  'export': (

    ExportInstance, ARGS_ONE_INSTANCE,

    "-n <target_node> [opts...] <name>",

    "Exports an instance to an image"),

  'import': (

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

    "Imports an instance from an exported image"),

  'remove': (

    "<name>", "Remove exports of named instance from the filesystem."),

  }

commands = {

  'init': (

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

     HVLIST_OPT, MAC_PREFIX_OPT, MASTER_NETDEV_OPT, NIC_PARAMS_OPT,

     NOLVM_STORAGE_OPT, NOMODIFY_ETCHOSTS_OPT, SECONDARY_IP_OPT, VG_NAME_OPT],

    "[opts...] <cluster_name>", "Initialises a new cluster configuration"),

  'destroy': (

    "", "Destroy cluster"),

  'rename': (

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

    "<new_name>",

    "Renames the cluster"),

  'redist-conf': (

    "", "Forces a push of the configuration file and ssconf files"

    " to the nodes in the cluster"),

  'verify': (

    VerifyCluster, ARGS_NONE,

    "", "Does a check on the cluster configuration"),

  'verify-disks': (

    "", "Does a check on the cluster disk status"),

  'repair-disk-sizes': (

    "", "Updates mismatches in recorded disk sizes"),

  'masterfailover': (

    "", "Makes the current node the master"),

  'version': (

    "", "Shows the cluster version"),

  'getmaster': (

    "", "Shows the cluster master"),

  'copyfile': (

    ClusterCopyFile, [ArgFile(min=1, max=1)],

    "[-n node...] <filename>", "Copies a file to all (or only some) nodes"),

  'command': (

    RunClusterCommand, [ArgCommand(min=1)],

    "[-n node...] <command>", "Runs a command on all (or only some) nodes"),

  'info': (

    "", "Show cluster configuration"),

  'list-tags': (

  'add-tags': (

    "tag...", "Add tags to the cluster"),

  'remove-tags': (

    "tag...", "Remove tags from the cluster"),

  'search-tags': (

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

    " the cluster for a given pattern (regex)"),

  'queue': (

    QueueOps,

    [ArgChoice(min=1, max=1, choices=["drain", "undrain", "info"])],

  'watcher': (

    WatcherOps,

    [ArgChoice(min=1, max=1, choices=["pause", "continue", "info"]),

     ArgSuggest(min=0, max=1, choices=["30m", "1h", "4h"])],

    "{pause <timespec>|continue|info}", "Change watcher properties"),

  'modify': (

    SetClusterParams, ARGS_NONE,

     NIC_PARAMS_OPT, NOLVM_STORAGE_OPT, VG_NAME_OPT],

    "[opts...]",

    "Alters the parameters of the cluster"),

commands = {

  'delay': (

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

                action="store_false", help="Do not sleep in the master code"),

     cli_option("-n", dest="on_nodes", default=[],

                action="append", help="Select nodes to sleep on"),

    "[opts...] <duration>", "Executes a TestDelay OpCode"),

  'submit-job': (

    GenericOpCodes, [ArgFile(min=1)],

     cli_option("--op-repeat", type="int", default="1", dest="rep_op",

                help="Repeat the opcode sequence this number of times"),

     cli_option("--job-repeat", type="int", default="1", dest="rep_job",

    " containing a list of serialized opcodes"),

  'allocator': (

    TestAllocator, ARGS_ONE_INSTANCE,

                default="in", choices=["in", "out"],

                help="Show allocator input (in) or allocator"

                " results (out)"),

# this is defined separately due to readability only

add_opts = [

  BACKEND_OPT,

  DISK_OPT,

  FILESTORE_DIR_OPT,

  FILESTORE_DRIVER_OPT,

  HYPERVISOR_OPT,

  SUBMIT_OPT,

  ]

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

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

  'batch-create': (

    "<instances.json>",

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

  'console': (

    ConnectToInstanceConsole, ARGS_ONE_INSTANCE,

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

  'failover': (

    FailoverInstance, ARGS_ONE_INSTANCE,

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

    " using the remote mirror (only for instances of type drbd)"),

  'migrate': (

    MigrateInstance, ARGS_ONE_INSTANCE,

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

    " (only for instances of type drbd)"),

  'move': (

    MoveInstance, ARGS_ONE_INSTANCE,

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

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

  'info': (

    ShowInstanceConfig, ARGS_MANY_INSTANCES,

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

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

  'list': (

    ListInstances, ARGS_MANY_INSTANCES,

    "[<instance>...]",

    "Lists the instances and their status. The available fields are"

    " (see the man page for details): status, oper_state, oper_ram,"

    ),

  'reinstall': (

    ReinstallInstance, [ArgInstance(min=1)],

     m_sec_node_opt, m_clust_opt, m_inst_opt, SELECT_OS_OPT, SUBMIT_OPT],

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

  'remove': (

    RemoveInstance, ARGS_ONE_INSTANCE,

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

  'rename': (

    RenameInstance,

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

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

  'replace-disks': (

    ReplaceDisks, ARGS_ONE_INSTANCE,

     NEW_SECONDARY_OPT, ON_PRIMARY_OPT, ON_SECONDARY_OPT, SUBMIT_OPT],

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

    "Replaces all disks for the instance"),

  'modify': (

    SetInstanceParams, ARGS_ONE_INSTANCE,

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

  'shutdown': (

    ShutdownInstance, [ArgInstance(min=1)],

     m_inst_opt, m_force_multi, SUBMIT_OPT],

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

  'startup': (

    StartupInstance, [ArgInstance(min=1)],

     m_sec_node_opt, m_clust_opt, m_inst_opt, SUBMIT_OPT, HVOPTS_OPT,

     BACKEND_OPT],

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

  'reboot': (

    RebootInstance, [ArgInstance(min=1)],

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

  'activate-disks': (

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

  'deactivate-disks': (

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

  'recreate-disks': (

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

  'grow-disk': (

    GrowDisk,

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

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

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

  'list-tags': (

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

  'add-tags': (

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

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

  'remove-tags': (

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

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

  }

commands = {

  'list': (

    ListJobs, [ArgJobId()],

    "[job_id ...]",

    "List the jobs and their status. The available fields are"

    " (see the man page for details): id, status, op_list,"

    " The default field"

    " list is (in order): %s." % ", ".join(_LIST_DEF_FIELDS)),

  'archive': (

    "<job-id> [<job-id> ...]", "Archive specified jobs"),

  'autoarchive': (

    AutoArchiveJobs,

    [ArgSuggest(min=1, max=1, choices=["1d", "1w", "4w"])],

    "<age>", "Auto archive jobs older than the given age"),

  'cancel': (

    "<job-id> [<job-id> ...]", "Cancel specified jobs"),

  'info': (

    "<job-id> [<job-id> ...]",

    "Show detailed information about the specified jobs"),

  'watch': (

    "<job-id>", "Follows a job and prints its output as it arrives"),

  }

commands = {

  'add': (

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

    "[-s ip] [--readd] [--no-ssh-key-check] <node_name>",

    "Add a node to the cluster"),

  'evacuate': (

    EvacuateNode, ARGS_ONE_NODE,

    "[-f] {-I <iallocator> | -n <dst>} <node>",

    "Relocate the secondary instances from a node"

    " to other nodes (only for instances with drbd disk template)"),

  'failover': (

    "[-f] <node>",

    "Stops the primary instances on a node and start them on their"

    " secondary node (only for instances with drbd disk template)"),

  'migrate': (

    "[-f] <node>",

    "Migrate all the primary instance on a node away from it"

    " (only for instances of type drbd)"),

  'info': (

    "[<node_name>...]", "Show information about the node(s)"),

  'list': (

    ListNodes, ARGS_MANY_NODES,

    "[nodes...]",

    "Lists the nodes in the cluster. The available fields are (see the man"

    " page for details): %s. The default field list is (in order): %s." %

    (", ".join(_LIST_HEADERS), ", ".join(_LIST_DEF_FIELDS))),

  'modify': (

    SetNodeParams, ARGS_ONE_NODE,

    "<node_name>", "Alters the parameters of a node"),

  'powercycle': (

    PowercycleNode, ARGS_ONE_NODE,

    "<node_name>", "Tries to forcefully powercycle a node"),

  'remove': (

    "<node_name>", "Removes a node from the cluster"),

  'volumes': (

    ListVolumes, [ArgNode()],

    "[<node_name>...]", "List logical volumes on node(s)"),

  'physical-volumes': (

    ListPhysicalVolumes, ARGS_MANY_NODES,

  'modify-volume': (

    ModifyVolume,

    [ArgNode(min=1, max=1),

     ArgChoice(min=1, max=1, choices=_MODIFIABLE_STORAGE_TYPES),

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

  'repair-volume': (

    RepairVolume,

    [ArgNode(min=1, max=1),

     ArgChoice(min=1, max=1, choices=_REPAIRABLE_STORAGE_TYPES),

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

    "<node_name> <storage_type> <name>",

    "Repairs a storage volume on a node"),

  'list-tags': (

    "<node_name>", "List the tags of the given node"),

  'add-tags': (

    "<node_name> tag...", "Add tags to the given node"),

  'remove-tags': (

    "<node_name> tag...", "Remove tags from the given node"),

  }

commands = {

  'list': (

  'diagnose': (

  }

if __name__ == '__main__':