Synnefo » snf-ganeti

import qualified Ganeti.Query.Export as Export

import Ganeti.Query.Filter

import qualified Ganeti.Query.Job as Query.Job

import Ganeti.Query.Language

import Ganeti.Query.Types

import Ganeti.Path

import Ganeti.Types

queryInner cfg live (Query (ItemTypeOpCode QRNode) fields qfilter) wanted =

  runResultT $ do

      (fdefs, fgetters, _) = unzip3 selected

      live' = live && needsLiveData fgetters

  nodes <- resultT $ case wanted of

                      nodes

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

  -- the nodes, based on existing runtime data

  let fdata = map (\(node, nrt) -> map (execGetter cfg nrt node) fgetters)

              nruntimes

  return QueryResult { qresFields = fdefs, qresData = fdata }

queryInner cfg _ (Query (ItemTypeOpCode QRGroup) fields qfilter) wanted =

  return $ do

      (fdefs, fgetters, _) = unzip3 selected

  groups <- case wanted of

              [] -> Ok . niceSortKey groupName .

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

  return QueryResult { qresFields = fdefs, qresData = fdata }

queryInner cfg _ (Query (ItemTypeOpCode QRNetwork) fields qfilter) wanted =

  return $ do

      (fdefs, fgetters, _) = unzip3 selected

  networks <- case wanted of

                [] -> Ok . niceSortKey (fromNonEmpty . networkName) .

                _  -> mapM (getNetwork cfg) wanted

  fnetworks <- filterM (\n -> evaluateFilter cfg Nothing n cfilter) networks

  let fdata = map (\network ->

                   fnetworks

  return QueryResult { qresFields = fdefs, qresData = fdata }

-- | Query fields call.

queryFields :: QueryFields -> ErrorResult QueryFieldsResult

queryFields (QueryFields (ItemTypeOpCode QRNode) fields) =

queryFields (QueryFields (ItemTypeOpCode QRGroup) fields) =

queryFields (QueryFields (ItemTypeLuxi QRJob) fields) =

  Ok $ fieldsExtractor Query.Job.fieldsMap fields