Synnefo » snf-ganeti » ganeti-local

      "User-Agent": self.USER_AGENT,

      }

    """Sends an HTTP request.

    This constructs a full URL, encodes and decodes HTTP bodies, and

    handles invalid responses in a pythonic way.

    @param method: HTTP method to use

    @param path: HTTP URL path

    @type query: list of two-tuples

    @param query: query arguments to pass to urllib.urlencode

    @return: Ganeti Remote API version

    """

  def GetOperatingSystems(self):

    """Gets the Operating Systems running in the Ganeti cluster.

    @return: operating systems

    """

  def GetInfo(self):

    """Gets info about the cluster.

    @return: information about the cluster

    """

  def GetClusterTags(self):

    """Gets the cluster tags.

    @return: cluster tags

    """

  def AddClusterTags(self, tags, dry_run=False):

    """Adds tags to the cluster.

    if dry_run:

      query.append(("dry-run", 1))

  def DeleteClusterTags(self, tags, dry_run=False):

    """Deletes tags from the cluster.

    if dry_run:

      query.append(("dry-run", 1))

  def GetInstances(self, bulk=False):

    """Gets information about instances on the cluster.

    if bulk:

      query.append(("bulk", 1))

    if bulk:

      return instances

    else:

    @return: info about the instance

    """

  def CreateInstance(self, dry_run=False):

    """Creates a new instance.

    if dry_run:

      query.append(("dry-run", 1))

  def DeleteInstance(self, instance, dry_run=False):

    """Deletes an instance.

    if dry_run:

      query.append(("dry-run", 1))

  def GetInstanceTags(self, instance):

    """Gets tags for an instance.

    @return: tags for the instance

    """

  def AddInstanceTags(self, instance, tags, dry_run=False):

    """Adds tags to an instance.

    if dry_run:

      query.append(("dry-run", 1))

  def DeleteInstanceTags(self, instance, tags, dry_run=False):

    """Deletes tags from an instance.

      query.append(("dry-run", 1))

    return self._SendRequest(HTTP_DELETE, "/2/instances/%s/tags" % instance,

  def RebootInstance(self, instance, reboot_type=None, ignore_secondaries=None,

                     dry_run=False):

      query.append(("dry-run", 1))

    return self._SendRequest(HTTP_POST, "/2/instances/%s/reboot" % instance,

  def ShutdownInstance(self, instance, dry_run=False):

    """Shuts down an instance.

      query.append(("dry-run", 1))

    return self._SendRequest(HTTP_PUT, "/2/instances/%s/shutdown" % instance,

  def StartupInstance(self, instance, dry_run=False):

    """Starts up an instance.

      query.append(("dry-run", 1))

    return self._SendRequest(HTTP_PUT, "/2/instances/%s/startup" % instance,

  def ReinstallInstance(self, instance, os, no_startup=False):

    """Reinstalls an instance.

    if no_startup:

      query.append(("nostartup", 1))

    return self._SendRequest(HTTP_POST, "/2/instances/%s/reinstall" % instance,

  def ReplaceInstanceDisks(self, instance, disks, mode="replace_auto",

                           remote_node=None, iallocator="hail", dry_run=False):

      query.append(("dry-run", 1))

    return self._SendRequest(HTTP_POST,

  def GetJobs(self):

    """Gets all jobs for the cluster.

    @return: job ids for the cluster

    """

  def GetJobStatus(self, job_id):

    """Gets the status of a job.

    @return: job status

    """

  def DeleteJob(self, job_id, dry_run=False):

    """Deletes a job.

    if dry_run:

      query.append(("dry-run", 1))

  def GetNodes(self, bulk=False):

    """Gets all nodes in the cluster.

    if bulk:

      query.append(("bulk", 1))

    if bulk:

      return nodes

    else:

    @return: info about the node

    """

  def EvacuateNode(self, node, iallocator=None, remote_node=None,

                   dry_run=False):

    if dry_run:

      query.append(("dry-run", 1))

  def MigrateNode(self, node, live=True, dry_run=False):

    """Migrates all primary instances from a node.

    if dry_run:

      query.append(("dry-run", 1))

  def GetNodeRole(self, node):

    """Gets the current role for a node.

    @return: the current role for a node

    """

  def SetNodeRole(self, node, role, force=False):

    """Sets the role for a node.

      raise InvalidNodeRole("%s is not a valid node role.", role)

    query = [("force", force)]

  def GetNodeStorageUnits(self, node, storage_type, output_fields):

    """Gets the storage units for a node.

      raise InvalidStorageType("%s is an invalid storage type.", storage_type)

    query = [("storage_type", storage_type), ("output_fields", output_fields)]

  def ModifyNodeStorageUnits(self, node, storage_type, name, allocatable=True):

    """Modifies parameters of storage units on the node.

        ("allocatable", allocatable)

        ]

    return self._SendRequest(HTTP_PUT, "/2/nodes/%s/storage/modify" % node,

  def RepairNodeStorageUnits(self, node, storage_type, name):

    """Repairs a storage unit on the node.

    query = [("storage_type", storage_type), ("name", name)]

    return self._SendRequest(HTTP_PUT, "/2/nodes/%s/storage/repair" % node,

  def GetNodeTags(self, node):

    """Gets the tags for a node.

    @return: tags for the node

    """

  def AddNodeTags(self, node, tags, dry_run=False):

    """Adds tags to a node.

    if dry_run:

      query.append(("dry-run", 1))

  def DeleteNodeTags(self, node, tags, dry_run=False):

    """Delete tags from a node.

    if dry_run:

      query.append(("dry-run", 1))