Synnefo » snf-ganeti

import Ganeti.Query.Node

import Ganeti.Query.Group

import Ganeti.Objects

-- * Helper functions

      -> Bool         -- ^ Whether to collect live data

      -> Query        -- ^ The query (item, fields, filter)

      -> IO (Result QueryResult) -- ^ Result

  cfilter <- resultT $ compileFilter nodeFieldsMap qfilter

  let selected = getSelectedFields nodeFieldsMap fields

      (fdefs, fgetters) = unzip selected

      live' = live && needsLiveData fgetters

  -- runs first pass of the filter, without a runtime context; this

  -- will limit the nodes that we'll contact for runtime data

  fnodes <- resultT $ filterM (\n -> evaluateFilter cfg Nothing n cfilter) nodes

              nruntimes

  return QueryResult { qresFields = fdefs, qresData = fdata }

  -- FIXME: want_diskparams is defaulted to false and not taken as parameter

  -- This is because the type for DiskParams is right now too generic for merges

  -- (or else I cannot see how to do this with curent implementation)

  cfilter <- compileFilter groupFieldsMap qfilter

  let selected = getSelectedFields groupFieldsMap fields

      (fdefs, fgetters) = unzip selected

  -- there is no live data for groups, so filtering is much simpler

  fgroups <- filterM (\n -> evaluateFilter cfg Nothing n cfilter) groups

  let fdata = map (\node ->

                       map (execGetter cfg GroupRuntime node) fgetters) fgroups

  return QueryResult {qresFields = fdefs, qresData = fdata }

  return . Bad $ "Query '" ++ show qkind ++ "' not supported"

-- | Query fields call.