Synnefo » snf-ganeti

import qualified Text.JSON as J

import Ganeti.BasicTypes

import Ganeti.Config

import Ganeti.JSON

import Ganeti.Rpc

query :: ConfigData   -- ^ The current configuration

      -> Bool         -- ^ Whether to collect live data

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

query cfg live qry = queryInner cfg live qry $ getRequestedNames qry

-- | Inner query execution function.

           -> Bool         -- ^ Whether to collect live data

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

           -> [String]     -- ^ Requested names

queryInner cfg live (Query QRNode fields qfilter) wanted = runResultT $ do

  cfilter <- resultT $ compileFilter nodeFieldsMap qfilter

             _  -> mapM (getNode cfg) wanted

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

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

  -- here we would run the runtime data gathering, then filter again

  -- the nodes, based on existing runtime data

  nruntimes <- lift $ maybeCollectLiveData live' cfg fnodes

  return QueryResult {qresFields = fdefs, qresData = fdata }

queryInner _ _ (Query qkind _ _) _ =

-- | Helper for 'queryFields'.

fieldsExtractor :: FieldMap a b -> [FilterField] -> QueryFieldsResult

  in QueryFieldsResult (map fst selected)

-- | Query fields call.

queryFields (QueryFields QRNode fields) =

  Ok $ fieldsExtractor nodeFieldsMap fields

  Ok $ fieldsExtractor groupFieldsMap fields

queryFields (QueryFields qkind _) =

-- | Classic query converter. It gets a standard query result on input

-- and computes the classic style results.

queryCompat (QueryResult fields qrdata) =

  case map fdefName $ filter ((== QFTUnknown) . fdefKind) fields of

    [] -> Ok $ map (map (maybe J.JSNull J.showJSON . rentryValue)) qrdata