Synnefo » snf-ganeti

    c.run()

    return c.getresult()

  def call_bridges_exist(self, node, bridges_list):

    """Checks if a node has all the bridges given.

    c.run()

    return c.getresult().get(node, False)

  def call_instance_start(self, node, instance, extra_args):

    """Starts an instance.

    c.run()

    return c.getresult().get(node, False)

  def call_instance_shutdown(self, node, instance):

    """Stops an instance.

    c.run()

    return c.getresult().get(node, False)

  def call_instance_migrate(self, node, instance, target, live):

    """Migrate an instance.

    c.run()

    return c.getresult().get(node, False)

  def call_instance_reboot(self, node, instance, reboot_type, extra_args):

    """Reboots an instance.

    c.run()

    return c.getresult().get(node, False)

  def call_instance_os_add(self, node, inst, osdev, swapdev):

    """Installs an OS on the given instance.

    c.run()

    return c.getresult().get(node, False)

  def call_instance_run_rename(self, node, inst, old_name, osdev, swapdev):

    """Run the OS rename script for an instance.

    c.run()

    return c.getresult().get(node, False)

  def call_instance_info(self, node, instance, hname):

    """Returns information about a single instance.

    @param hname: the hypervisor type of the instance

    """

    c.connect(node)

    c.run()

    return c.getresult().get(node, False)

  def call_all_instances_info(self, node_list, hypervisor_list):

    """Returns information about all instances on the given nodes.

    c.run()

    return c.getresult()

  def call_instance_list(self, node_list, hypervisor_list):

    """Returns the list of running instances on a given node.

    c.run()

    return c.getresult()

  def call_node_tcp_ping(self, node, source, target, port, timeout,

                         live_port_needed):

    """Do a TcpPing on the remote node

                      )

    return retux

  def call_node_add(self, node, dsa, dsapub, rsa, rsapub, ssh, sshpub):

    """Add a node to the cluster.

    c.run()

    return c.getresult().get(node, False)

  def call_node_verify(self, node_list, checkdict, cluster_name):

    """Request verification of given parameters.

    c.run()

    return c.getresult()

  @staticmethod

  def call_node_start_master(node, start_daemons):

    """Tells a node to activate itself as a master.

    c.run()

    return c.getresult().get(node, False)

  @staticmethod

  def call_node_stop_master(node, stop_daemons):

    """Tells a node to demote itself from master status.

    c.run()

    return c.getresult().get(node, False)

  @staticmethod

  def call_master_info(node_list):

    """Query master info.

    c.run()

    return c.getresult()

  def call_version(self, node_list):

    """Query node version.

    c.run()

    return c.getresult()

  def call_blockdev_create(self, node, bdev, size, owner, on_primary, info):

    """Request creation of a given block device.

    c.run()

    return c.getresult().get(node, False)

  def call_blockdev_remove(self, node, bdev):

    """Request removal of a given block device.

    c.run()

    return c.getresult().get(node, False)

  def call_blockdev_rename(self, node, devlist):

    """Request rename of the given block devices.

    c.run()

    return c.getresult().get(node, False)

  def call_blockdev_assemble(self, node, disk, owner, on_primary):

    """Request assembling of a given block device.

    c.run()

    return c.getresult().get(node, False)

  def call_blockdev_shutdown(self, node, disk):

    """Request shutdown of a given block device.

    c.run()

    return c.getresult().get(node, False)

  def call_blockdev_addchildren(self, node, bdev, ndevs):

    """Request adding a list of children to a (mirroring) device.

    c.run()

    return c.getresult().get(node, False)

  def call_blockdev_removechildren(self, node, bdev, ndevs):

    """Request removing a list of children from a (mirroring) device.

    c.run()

    return c.getresult().get(node, False)

  def call_blockdev_getmirrorstatus(self, node, disks):

    """Request status of a (mirroring) device.

    c.run()

    return c.getresult().get(node, False)

  def call_blockdev_find(self, node, disk):

    """Request identification of a given block device.

    c.run()

    return c.getresult().get(node, False)

  def call_blockdev_close(self, node, disks):

    """Closes the given block devices.

    c.run()

    return c.getresult().get(node, False)

  @staticmethod

  def call_upload_file(node_list, file_name):

    """Upload a file.

      new_result[node_name] = nr

    return new_result

  def call_os_get(self, node, name):

    """Returns an OS definition.

    else:

      return result

  def call_hooks_runner(self, node_list, hpath, phase, env):

    """Call the hooks runner.

    result = c.getresult()

    return result

  def call_iallocator_runner(self, node, name, idata):

    """Call an iallocator on a remote node

    result = c.getresult().get(node, False)

    return result

  def call_blockdev_grow(self, node, cf_bdev, amount):

    """Request a snapshot of the given block device.

    c.run()

    return c.getresult().get(node, False)

  def call_blockdev_snapshot(self, node, cf_bdev):

    """Request a snapshot of the given block device.

    c.run()

    return c.getresult().get(node, False)

  def call_snapshot_export(self, node, snap_bdev, dest_node, instance,

                           cluster_name):

    """Request the export of a given snapshot.

    c.run()

    return c.getresult().get(node, False)

  def call_finalize_export(self, node, instance, snap_disks):

    """Request the completion of an export operation.

    c.run()

    return c.getresult().get(node, False)

  def call_export_info(self, node, path):

    """Queries the export information in a given path.

      return result

    return objects.SerializableConfigParser.Loads(str(result))

  def call_instance_os_import(self, node, inst, osdev, swapdev,

                              src_node, src_image, cluster_name):

    """Request the import of a backup into an instance.

    c.run()

    return c.getresult().get(node, False)

  def call_export_list(self, node_list):

    """Gets the stored exports list.

    result = c.getresult()

    return result

  def call_export_remove(self, node, export):

    """Requests removal of a given export.

    c.run()

    return c.getresult().get(node, False)

  @staticmethod

  def call_node_leave_cluster(node):

    """Requests a node to clean the cluster information it has.

    c.run()

    return c.getresult().get(node, False)

  def call_node_volumes(self, node_list):

    """Gets all volumes on node(s).

    c.run()

    return c.getresult()

  def call_test_delay(self, node_list, duration):

    """Sleep for a fixed time on given node(s).

    c.run()

    return c.getresult()

  def call_file_storage_dir_create(self, node, file_storage_dir):

    """Create the given file storage directory.

    c.run()

    return c.getresult().get(node, False)

  def call_file_storage_dir_remove(self, node, file_storage_dir):

    """Remove the given file storage directory.

    c.run()

    return c.getresult().get(node, False)

  def call_file_storage_dir_rename(self, node, old_file_storage_dir,

                                   new_file_storage_dir):

    """Rename file storage directory.

    c.run()

    return c.getresult().get(node, False)

  @staticmethod

  def call_jobqueue_update(node_list, file_name, content):

    """Update job queue.

    result = c.getresult()

    return result

  @staticmethod

  def call_jobqueue_purge(node):

    """Purge job queue.

    c.run()

    return c.getresult().get(node, False)

  @staticmethod

  def call_jobqueue_rename(node_list, old, new):

    """Rename a job queue file.