Synnefo » snf-ganeti » ganeti-local

    self._port = port

    self._logger = logger

    self._base_url = "https://%s:%s" % (host, port)

    handlers = [_HTTPSHandler(self._logger, config_ssl_verification)]

      "User-Agent": self.USER_AGENT,

      }

    """Constructs the URL to pass to the HTTP client.

    @type path: str

    @param path: HTTP URL path

    @type query: list of two-tuples

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

    @rtype:  str

    @return: URL path

    """

    return "https://%(host)s:%(port)d%(path)s?%(query)s" % {

        "host": self._host,

        "port": self._port,

        "path": path,

        "query": urllib.urlencode(query or [])}

    """Sends an HTTP request.

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

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

    @type content: str or None

    @param content: HTTP body content

    @rtype: str

    @return: JSON-Decoded response

    if content:

      content = simplejson.JSONEncoder(sort_keys=True).encode(content)

    req = _RapiRequest(method, url, self._headers, content)

    @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.

    if dry_run:

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

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

                     dry_run=False):

    if dry_run:

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

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

    """Shuts down an instance.

    if dry_run:

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

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

    """Starts up an instance.

    if dry_run:

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

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

    """Reinstalls an instance.

    query = [("os", os)]

    if no_startup:

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

  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)]

                             content=role)

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

      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.

        ("storage_type", storage_type), ("name", name),

        ("allocatable", allocatable)

        ]

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

    """Repairs a storage unit on the node.

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

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

  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))

                             content=tags)

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

    if dry_run:

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