Synnefo » snf-ganeti » ganeti-local

  , RpcCallStorageList(..)

  , RpcResultStorageList(..)

  , rpcTimeoutFromRaw -- FIXME: Not used anywhere

  ) where

import Ganeti.Compat

import Ganeti.JSON

#ifndef NO_CURL

-- | The curl options used for RPC.

curlOpts :: [CurlOption]

-- * RPC calls and results

-- | InstanceInfo

--   Returns information about a single instance.

      _ -> Left $ JsonDecodeError

           ("Expected JSObject, got " ++ show (pp_value res))

-- | AllInstancesInfo

--   Returns information about all running instances on the given nodes

$(buildObject "RpcCallAllInstancesInfo" "rpcCallAllInstInfo"

      _ -> Left $ JsonDecodeError

           ("Expected JSObject, got " ++ show (pp_value res))

-- | InstanceList

-- Returns the list of running instances on the given nodes.

$(buildObject "RpcCallInstanceList" "rpcCallInstList"

instance Rpc RpcCallInstanceList RpcResultInstanceList where

  rpcResultFill _ res = fromJSValueToRes res RpcResultInstanceList

-- | NodeInfo

-- Return node information.

$(buildObject "RpcCallNodeInfo" "rpcCallNodeInfo"

  rpcResultFill _ res =

    fromJSValueToRes res (\(b, vg, hv) -> RpcResultNodeInfo b vg hv)

-- | Version

-- Query node version.

-- Note: We can't use THH as it does not know what to do with empty dict

instance Rpc RpcCallVersion RpcResultVersion where

  rpcResultFill _ res = fromJSValueToRes res RpcResultVersion

-- | StorageList

-- Get list of storage units.

-- FIXME: This may be moved to Objects

  rpcResultFill call res =

    let sfields = rpcCallStorageListFields call in

    fromJSValueToRes res (RpcResultStorageList . map (zip sfields))