Synnefo » snf-ganeti

{-

This program is free software; you can redistribute it and/or modify

it under the terms of the GNU General Public License as published by

-}

module Ganeti.Query.Node

  ) where

import Control.Applicative

import Ganeti.Query.Common

import Ganeti.Query.Types

-- | List of node live fields.

nodeLiveFieldsDefs :: [(FieldName, FieldTitle, FieldType, String, FieldDoc)]

nodeLiveFieldExtract _ _ = J.JSNull

-- | Helper for extracting field from RPC result.

nodeLiveRpcCall fname (Right res) _ =

  case nodeLiveFieldExtract fname res of

    J.JSNull -> rsNoData

-- | Builder for node live fields.

nodeLiveFieldBuilder :: (FieldName, FieldTitle, FieldType, String, FieldDoc)

nodeLiveFieldBuilder (fname, ftitle, ftype, _, fdoc) =

  ( FieldDefinition fname ftitle ftype fdoc

  , FieldRuntime $ nodeLiveRpcCall fname

                  else rsNormal (nodePowered node)

-- | List of all node fields.

nodeFields =

  [ (FieldDefinition "drained" "Drained" QFTBool "Whether node is drained",

     FieldSimple (rsNormal . nodeDrained), QffNormal)

  tagsFields

-- | The node fields map.

  Map.fromList $ map (\v@(f, _, _) -> (fdefName f, v)) nodeFields

-- | Collect live data from RPC query if enabled.

--

-- FIXME: Check which fields we actually need and possibly send empty

-- required

  return $ zip nodes (repeat $ Left (RpcResultError "Live data disabled"))

  let vgs = [clusterVolumeGroupName $ configCluster cfg]

      hvs = [getDefaultHypervisor cfg]

      step n (bn, gn, em) =