Synnefo » snf-ganeti

                format_override=None, verbose=False):

  """Generic implementation for listing all items of a resource.

  @type fields: list of strings

  @param fields: List of fields to query for

  @type names: list of strings

def GenericListFields(resource, fields, separator, header, cl=None):

  """Generic implementation for listing fields for a resource.

  @type fields: list of strings

  @param fields: List of fields to query for

  @type separator: string or None

  constants.QR_OS: _OsQuery,

  }

def _GetQueryImplementation(name):

  """Returns the implemtnation for a query type.

  """

  try:

QR_OS = "os"

#: List of resources which can be queried using L{opcodes.OpQuery}

#: List of resources which can be queried using Local UniX Interface

  QR_LOCK,

  ])

# Query field types

QFT_UNKNOWN = "unknown"

QFT_TEXT = "text"

  def Query(self, what, fields, filter_):

    """Query for resources/items.

    @type fields: List of strings

    @param fields: List of requested fields

    @type filter_: None or list

  def QueryFields(self, what, fields):

    """Query for available fields.

    @type fields: None or list of strings

    @param fields: List of requested fields

    @rtype: L{objects.QueryFieldsResponse}

_PGroupNodeParams = ("ndparams", None, ht.TMaybeDict,

                     "Default node parameters for group")

               "Resource(s) to query for")

_PIpCheckDoc = "Whether to ensure instance's IP address is inactive"

class OpQuery(OpCode):

  """Query for resources/items.

  @ivar fields: List of fields to retrieve

  @ivar filter: Query filter

class OpQueryFields(OpCode):

  """Query for available resource/item fields.

  @ivar fields: List of fields to retrieve

  """

    elif method == luxi.REQ_QUERY:

      req = objects.QueryRequest.FromDict(args)

        result = self._Query(opcodes.OpQuery(what=req.what, fields=req.fields,

                                             filter=req.filter))

      elif req.what == constants.QR_LOCK:

        if req.filter is not None:

          raise errors.OpPrereqError("Lock queries can't be filtered")

        return self.server.context.glm.QueryLocks(req.fields)

        raise NotImplementedError

      else:

        raise errors.OpPrereqError("Resource type '%s' unknown" % req.what,

    elif method == luxi.REQ_QUERY_FIELDS:

      req = objects.QueryFieldsRequest.FromDict(args)

        result = self._Query(opcodes.OpQueryFields(what=req.what,

                                                   fields=req.fields))

      elif req.what == constants.QR_LOCK:

        return query.QueryFields(query.LOCK_FIELDS, req.fields)

        raise NotImplementedError

      else:

        raise errors.OpPrereqError("Resource type '%s' unknown" % req.what,

class TestLUQuery(unittest.TestCase):

  def test(self):

    self.assertEqual(sorted(cmdlib._QUERY_IMPL.keys()),

      self.assert_(cmdlib._GetQueryImplementation(i))

    self.assertRaises(errors.OpPrereqError, cmdlib._GetQueryImplementation, "")