Synnefo » snf-ganeti » ganeti-local

import qa_error

from qa_utils import (AssertEqual, AssertIn, AssertMatch, StartLocalCommand)

_rapi_ca = None

        ])

def TestInstance(instance):

  """Testing getting instance(s) info via remote API.

    raise

def TestRapiInstanceRemove(instance, use_client):

  """Test removing instance via RAPI"""

  if use_client:

  qa_config.ReleaseInstance(instance)

def TestRapiInstanceMigrate(instance):

  """Test migrating instance via RAPI"""

  # Move to secondary node

  _WaitForRapiJob(_rapi_client.MigrateInstance(instance["name"]))

  # And back to previous primary

  _WaitForRapiJob(_rapi_client.MigrateInstance(instance["name"]))

def TestRapiInstanceFailover(instance):

  """Test failing over instance via RAPI"""

  # Move to secondary node

  _WaitForRapiJob(_rapi_client.FailoverInstance(instance["name"]))

  # And back to previous primary

  _WaitForRapiJob(_rapi_client.FailoverInstance(instance["name"]))

def TestRapiInstanceShutdown(instance):

  """Test stopping an instance via RAPI"""

  _WaitForRapiJob(_rapi_client.ShutdownInstance(instance["name"]))

def TestRapiInstanceStartup(instance):

  """Test starting an instance via RAPI"""

  _WaitForRapiJob(_rapi_client.StartupInstance(instance["name"]))

def TestRapiInstanceRenameAndBack(rename_source, rename_target):

  """Test renaming instance via RAPI

  """

  _WaitForRapiJob(_rapi_client.RenameInstance(rename_source, rename_target))

  _WaitForRapiJob(_rapi_client.RenameInstance(rename_target, rename_source))

def TestRapiInstanceReinstall(instance):

  """Test reinstalling an instance via RAPI"""

  _WaitForRapiJob(_rapi_client.ReinstallInstance(instance["name"]))

def TestRapiInstanceReplaceDisks(instance):

  """Test replacing instance disks via RAPI"""

  _WaitForRapiJob(_rapi_client.ReplaceInstanceDisks(instance["name"],

    mode=constants.REPLACE_DISK_SEC, disks="0"))

def TestRapiInstanceModify(instance):

  """Test modifying instance via RAPI"""

  def _ModifyInstance(**kwargs):

    })

def TestRapiInstanceConsole(instance):

  """Test getting instance console information via RAPI"""

  result = _rapi_client.GetInstanceConsole(instance["name"])

  AssertEqual(console.instance, qa_utils.ResolveInstanceName(instance["name"]))

def TestRapiStoppedInstanceConsole(instance):

  """Test getting stopped instance's console information via RAPI"""

  try:

      si,

      ]

    AssertEqual(StartLocalCommand(cmd).wait(), 0)