Source Code for Module ganeti.client.gnt_backup

  1  # 
  2  # 
  3   
  4  # Copyright (C) 2006, 2007, 2010 Google Inc. 
  5  # 
  6  # This program is free software; you can redistribute it and/or modify 
  7  # it under the terms of the GNU General Public License as published by 
  8  # the Free Software Foundation; either version 2 of the License, or 
  9  # (at your option) any later version. 
 10  # 
 11  # This program is distributed in the hope that it will be useful, but 
 12  # WITHOUT ANY WARRANTY; without even the implied warranty of 
 13  # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU 
 14  # General Public License for more details. 
 15  # 
 16  # You should have received a copy of the GNU General Public License 
 17  # along with this program; if not, write to the Free Software 
 18  # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 
 19  # 02110-1301, USA. 
 20   
 21  """Backup related commands""" 
 22   
 23  # pylint: disable-msg=W0401,W0613,W0614,C0103 
 24  # W0401: Wildcard import ganeti.cli 
 25  # W0613: Unused argument, since all functions follow the same API 
 26  # W0614: Unused import %s from wildcard import (since we need cli) 
 27  # C0103: Invalid name gnt-backup 
 28   
 29  from ganeti.cli import * 
 30  from ganeti import opcodes 
 31  from ganeti import constants 
 32  from ganeti import errors 
 33   
 34   
 35  _VALUE_TRUE = "true" 
 36   
 37   
 38 -def PrintExportList(opts, args): 
 39    """Prints a list of all the exported system images. 
 40   
 41    @param opts: the command line options selected by the user 
 42    @type args: list 
 43    @param args: should be an empty list 
 44    @rtype: int 
 45    @return: the desired exit code 
 46   
 47    """ 
 48    exports = GetClient().QueryExports(opts.nodes, False) 
 49    retcode = 0 
 50    for node in exports: 
 51      ToStdout("Node: %s", node) 
 52      ToStdout("Exports:") 
 53      if isinstance(exports[node], list): 
 54        for instance_name in exports[node]: 
 55          ToStdout("\t%s", instance_name) 
 56      else: 
 57        ToStdout("  Could not get exports list") 
 58        retcode = 1 
 59    return retcode 
 60   
 61   
 62 -def ExportInstance(opts, args): 
 63    """Export an instance to an image in the cluster. 
 64   
 65    @param opts: the command line options selected by the user 
 66    @type args: list 
 67    @param args: should contain only one element, the name 
 68        of the instance to be exported 
 69    @rtype: int 
 70    @return: the desired exit code 
 71   
 72    """ 
 73    ignore_remove_failures = opts.ignore_remove_failures 
 74   
 75    if not opts.node: 
 76      raise errors.OpPrereqError("Target node must be specified", 
 77                                 errors.ECODE_INVAL) 
 78   
 79    op = opcodes.OpExportInstance(instance_name=args[0], 
 80                                  target_node=opts.node, 
 81                                  shutdown=opts.shutdown, 
 82                                  shutdown_timeout=opts.shutdown_timeout, 
 83                                  remove_instance=opts.remove_instance, 
 84                                  ignore_remove_failures=ignore_remove_failures) 
 85   
 86    SubmitOpCode(op, opts=opts) 
 87    return 0 
 88   
 89   
 90 -def ImportInstance(opts, args): 
 91    """Add an instance to the cluster. 
 92   
 93    This is just a wrapper over GenericInstanceCreate. 
 94   
 95    """ 
 96    return GenericInstanceCreate(constants.INSTANCE_IMPORT, opts, args) 
 97   
 98   
 99 -def RemoveExport(opts, args): 
100    """Remove an export from the cluster. 
101   
102    @param opts: the command line options selected by the user 
103    @type args: list 
104    @param args: should contain only one element, the name of the 
105        instance whose backup should be removed 
106    @rtype: int 
107    @return: the desired exit code 
108   
109    """ 
110    op = opcodes.OpRemoveExport(instance_name=args[0]) 
111   
112    SubmitOpCode(op, opts=opts) 
113    return 0 
114   
115   
116  # this is defined separately due to readability only 
117  import_opts = [ 
118    IDENTIFY_DEFAULTS_OPT, 
119    SRC_DIR_OPT, 
120    SRC_NODE_OPT, 
121    ] 
122   
123   
124  commands = { 
125    'list': ( 
126      PrintExportList, ARGS_NONE, 
127      [NODE_LIST_OPT], 
128      "", "Lists instance exports available in the ganeti cluster"), 
129    'export': ( 
130      ExportInstance, ARGS_ONE_INSTANCE, 
131      [FORCE_OPT, SINGLE_NODE_OPT, NOSHUTDOWN_OPT, SHUTDOWN_TIMEOUT_OPT, 
132       REMOVE_INSTANCE_OPT, IGNORE_REMOVE_FAILURES_OPT, DRY_RUN_OPT, 
133       PRIORITY_OPT], 
134      "-n <target_node> [opts...] <name>", 
135      "Exports an instance to an image"), 
136    'import': ( 
137      ImportInstance, ARGS_ONE_INSTANCE, COMMON_CREATE_OPTS + import_opts, 
138      "[...] -t disk-type -n node[:secondary-node] <name>", 
139      "Imports an instance from an exported image"), 
140    'remove': ( 
141      RemoveExport, [ArgUnknown(min=1, max=1)], [DRY_RUN_OPT, PRIORITY_OPT], 
142      "<name>", "Remove exports of named instance from the filesystem."), 
143    } 
144   
145   
146 -def Main(): 
147    return GenericMain(commands) 
148