Ganeti.Rpc

Contents

• Base RPC functionality and types
• RPC calls and results
  • Instance info
  • AllInstancesInfo
  • InstanceConsoleInfo
  • InstanceList
  • NodeInfo
  • Version
  • StorageList
  • TestDelay
  • ExportList
  • Job Queue Replication
  • Watcher Status Update
  • Queue drain status

Description

Synopsis

• curlOpts :: [CurlOption]
• data RpcError
  • = CurlLayerError String
  • | JsonDecodeError String
  • | RpcResultError String
  • | OfflineNodeError
• explainRpcError :: RpcError -> String
• type ERpcError = Either RpcError
• class JSON a => RpcCall a where
  • rpcCallName :: a -> String
  • rpcCallTimeout :: a -> Int
  • rpcCallData :: Node -> a -> String
  • rpcCallAcceptOffline :: a -> Bool
• class (RpcCall a, JSON b) => Rpc a b | a -> b, b -> a where
  • rpcResultFill :: a -> JSValue -> ERpcError b
• data HttpClientRequest = HttpClientRequest {
  • requestUrl :: String
  • requestData :: String
  • requestOpts :: [CurlOption]
  }
• isIpV6 :: String -> Bool
• prepareUrl :: RpcCall a => Node -> a -> String
• prepareHttpRequest :: RpcCall a => [CurlOption] -> Node -> a -> ERpcError HttpClientRequest
• parseHttpReply :: Rpc a b => a -> ERpcError (CurlCode, String) -> ERpcError b
• parseHttpResponse :: Rpc a b => a -> String -> ERpcError b
• logRpcErrors :: [(a, ERpcError b)] -> IO ()
• getOptionsForCall :: Rpc a b => FilePath -> FilePath -> a -> [CurlOption]
• executeRpcCalls :: Rpc a b => [(Node, a)] -> IO [(Node, ERpcError b)]
• executeRpcCall :: Rpc a b => [Node] -> a -> IO [(Node, ERpcError b)]
• sanitizeDictResults :: [(String, Result a)] -> ERpcError [(String, a)]
• fromJResultToRes :: Result a -> (a -> b) -> ERpcError b
• fromJSValueToRes :: JSON a => JSValue -> (a -> b) -> ERpcError b
• data RpcCallInstanceInfo = RpcCallInstanceInfo {
  • rpcCallInstInfoInstance :: String
  • rpcCallInstInfoHname :: Hypervisor
  }
• loadRpcCallInstanceInfo :: JSValue -> Result RpcCallInstanceInfo
• saveRpcCallInstanceInfo :: RpcCallInstanceInfo -> JSValue
• toDictRpcCallInstanceInfo :: RpcCallInstanceInfo -> [(String, JSValue)]
• data InstanceState
  • = InstanceStateRunning
  • | InstanceStateShutdown
• instanceStateFromRaw :: forall m. Monad m => Int -> m InstanceState
• instanceStateToRaw :: InstanceState -> Int
• _InstanceStateShutdown :: Int
• _InstanceStateRunning :: Int
• data InstanceInfo = InstanceInfo {
  • instInfoMemory :: Int
  • instInfoState :: InstanceState
  • instInfoVcpus :: Int
  • instInfoTime :: Int
  }
• loadInstanceInfo :: JSValue -> Result InstanceInfo
• saveInstanceInfo :: InstanceInfo -> JSValue
• toDictInstanceInfo :: InstanceInfo -> [(String, JSValue)]
• data RpcResultInstanceInfo = RpcResultInstanceInfo {
  • rpcResInstInfoInstInfo :: Maybe InstanceInfo
  }
• loadRpcResultInstanceInfo :: JSValue -> Result RpcResultInstanceInfo
• saveRpcResultInstanceInfo :: RpcResultInstanceInfo -> JSValue
• toDictRpcResultInstanceInfo :: RpcResultInstanceInfo -> [(String, JSValue)]
• data RpcCallAllInstancesInfo = RpcCallAllInstancesInfo {
  • rpcCallAllInstInfoHypervisors :: [(Hypervisor, HvParams)]
  }
• loadRpcCallAllInstancesInfo :: JSValue -> Result RpcCallAllInstancesInfo
• saveRpcCallAllInstancesInfo :: RpcCallAllInstancesInfo -> JSValue
• toDictRpcCallAllInstancesInfo :: RpcCallAllInstancesInfo -> [(String, JSValue)]
• data RpcResultAllInstancesInfo = RpcResultAllInstancesInfo {
  • rpcResAllInstInfoInstances :: [(String, InstanceInfo)]
  }
• loadRpcResultAllInstancesInfo :: JSValue -> Result RpcResultAllInstancesInfo
• saveRpcResultAllInstancesInfo :: RpcResultAllInstancesInfo -> JSValue
• toDictRpcResultAllInstancesInfo :: RpcResultAllInstancesInfo -> [(String, JSValue)]
• data InstanceConsoleInfoParams = InstanceConsoleInfoParams {
  • instConsInfoParamsInstance :: Instance
  • instConsInfoParamsNode :: Node
  • instConsInfoParamsGroup :: NodeGroup
  • instConsInfoParamsHvParams :: HvParams
  • instConsInfoParamsBeParams :: FilledBeParams
  }
• loadInstanceConsoleInfoParams :: JSValue -> Result InstanceConsoleInfoParams
• saveInstanceConsoleInfoParams :: InstanceConsoleInfoParams -> JSValue
• toDictInstanceConsoleInfoParams :: InstanceConsoleInfoParams -> [(String, JSValue)]
• data RpcCallInstanceConsoleInfo = RpcCallInstanceConsoleInfo {
  • rpcCallInstConsInfoInstanceInfo :: [(String, InstanceConsoleInfoParams)]
  }
• loadRpcCallInstanceConsoleInfo :: JSValue -> Result RpcCallInstanceConsoleInfo
• saveRpcCallInstanceConsoleInfo :: RpcCallInstanceConsoleInfo -> JSValue
• toDictRpcCallInstanceConsoleInfo :: RpcCallInstanceConsoleInfo -> [(String, JSValue)]
• data InstanceConsoleInfo = InstanceConsoleInfo {
  • instConsInfoInstance :: String
  • instConsInfoKind :: String
  • instConsInfoMessage :: Maybe String
  • instConsInfoHost :: Maybe String
  • instConsInfoPort :: Maybe Int
  • instConsInfoUser :: Maybe String
  • instConsInfoCommand :: Maybe [String]
  • instConsInfoDisplay :: Maybe String
  }
• loadInstanceConsoleInfo :: JSValue -> Result InstanceConsoleInfo
• saveInstanceConsoleInfo :: InstanceConsoleInfo -> JSValue
• toDictInstanceConsoleInfo :: InstanceConsoleInfo -> [(String, JSValue)]
• data RpcResultInstanceConsoleInfo = RpcResultInstanceConsoleInfo {
  • rpcResInstConsInfoInstancesInfo :: [(String, InstanceConsoleInfo)]
  }
• loadRpcResultInstanceConsoleInfo :: JSValue -> Result RpcResultInstanceConsoleInfo
• saveRpcResultInstanceConsoleInfo :: RpcResultInstanceConsoleInfo -> JSValue
• toDictRpcResultInstanceConsoleInfo :: RpcResultInstanceConsoleInfo -> [(String, JSValue)]
• data RpcCallInstanceList = RpcCallInstanceList {
  • rpcCallInstListHypervisors :: [Hypervisor]
  }
• loadRpcCallInstanceList :: JSValue -> Result RpcCallInstanceList
• saveRpcCallInstanceList :: RpcCallInstanceList -> JSValue
• toDictRpcCallInstanceList :: RpcCallInstanceList -> [(String, JSValue)]
• data RpcResultInstanceList = RpcResultInstanceList {
  • rpcResInstListInstances :: [String]
  }
• loadRpcResultInstanceList :: JSValue -> Result RpcResultInstanceList
• saveRpcResultInstanceList :: RpcResultInstanceList -> JSValue
• toDictRpcResultInstanceList :: RpcResultInstanceList -> [(String, JSValue)]
• data RpcCallNodeInfo = RpcCallNodeInfo {
  • rpcCallNodeInfoStorageUnits :: Map String [StorageUnit]
  • rpcCallNodeInfoHypervisors :: [(Hypervisor, HvParams)]
  }
• loadRpcCallNodeInfo :: JSValue -> Result RpcCallNodeInfo
• saveRpcCallNodeInfo :: RpcCallNodeInfo -> JSValue
• toDictRpcCallNodeInfo :: RpcCallNodeInfo -> [(String, JSValue)]
• data StorageInfo = StorageInfo {
  • storageInfoName :: String
  • storageInfoType :: String
  • storageInfoStorageFree :: Maybe Int
  • storageInfoStorageSize :: Maybe Int
  }
• loadStorageInfo :: JSValue -> Result StorageInfo
• saveStorageInfo :: StorageInfo -> JSValue
• toDictStorageInfo :: StorageInfo -> [(String, JSValue)]
• data HvInfo = HvInfo {
  • hvInfoMemoryTotal :: Int
  • hvInfoMemoryFree :: Int
  • hvInfoMemoryDom0 :: Int
  • hvInfoCpuTotal :: Int
  • hvInfoCpuNodes :: Int
  • hvInfoCpuSockets :: Int
  • hvInfoCpuDom0 :: Int
  }
• loadHvInfo :: JSValue -> Result HvInfo
• saveHvInfo :: HvInfo -> JSValue
• toDictHvInfo :: HvInfo -> [(String, JSValue)]
• data RpcResultNodeInfo = RpcResultNodeInfo {
  • rpcResNodeInfoBootId :: String
  • rpcResNodeInfoStorageInfo :: [StorageInfo]
  • rpcResNodeInfoHvInfo :: [HvInfo]
  }
• loadRpcResultNodeInfo :: JSValue -> Result RpcResultNodeInfo
• saveRpcResultNodeInfo :: RpcResultNodeInfo -> JSValue
• toDictRpcResultNodeInfo :: RpcResultNodeInfo -> [(String, JSValue)]
• data RpcCallVersion = RpcCallVersion {
  }
• loadRpcCallVersion :: JSValue -> Result RpcCallVersion
• saveRpcCallVersion :: RpcCallVersion -> JSValue
• toDictRpcCallVersion :: RpcCallVersion -> [(String, JSValue)]
• data RpcResultVersion = RpcResultVersion {
  • rpcResultVersionVersion :: Int
  }
• loadRpcResultVersion :: JSValue -> Result RpcResultVersion
• saveRpcResultVersion :: RpcResultVersion -> JSValue
• toDictRpcResultVersion :: RpcResultVersion -> [(String, JSValue)]
• data RpcCallStorageList = RpcCallStorageList {
  • rpcCallStorageListSuName :: StorageType
  • rpcCallStorageListSuArgs :: [String]
  • rpcCallStorageListName :: String
  • rpcCallStorageListFields :: [StorageField]
  }
• loadRpcCallStorageList :: JSValue -> Result RpcCallStorageList
• saveRpcCallStorageList :: RpcCallStorageList -> JSValue
• toDictRpcCallStorageList :: RpcCallStorageList -> [(String, JSValue)]
• data RpcResultStorageList = RpcResultStorageList {
  • rpcResStorageListStorage :: [[(StorageField, JSValue)]]
  }
• loadRpcResultStorageList :: JSValue -> Result RpcResultStorageList
• saveRpcResultStorageList :: RpcResultStorageList -> JSValue
• toDictRpcResultStorageList :: RpcResultStorageList -> [(String, JSValue)]
• data RpcCallTestDelay = RpcCallTestDelay {
  • rpcCallTestDelayDuration :: Double
  }
• loadRpcCallTestDelay :: JSValue -> Result RpcCallTestDelay
• saveRpcCallTestDelay :: RpcCallTestDelay -> JSValue
• toDictRpcCallTestDelay :: RpcCallTestDelay -> [(String, JSValue)]
• data RpcResultTestDelay = RpcResultTestDelay
• data RpcCallExportList = RpcCallExportList {
  }
• loadRpcCallExportList :: JSValue -> Result RpcCallExportList
• saveRpcCallExportList :: RpcCallExportList -> JSValue
• toDictRpcCallExportList :: RpcCallExportList -> [(String, JSValue)]
• data RpcResultExportList = RpcResultExportList {
  • rpcResExportListExports :: [String]
  }
• loadRpcResultExportList :: JSValue -> Result RpcResultExportList
• saveRpcResultExportList :: RpcResultExportList -> JSValue
• toDictRpcResultExportList :: RpcResultExportList -> [(String, JSValue)]
• data RpcCallJobqueueUpdate = RpcCallJobqueueUpdate {
  • rpcCallJobqueueUpdateFileName :: String
  • rpcCallJobqueueUpdateContent :: String
  }
• loadRpcCallJobqueueUpdate :: JSValue -> Result RpcCallJobqueueUpdate
• saveRpcCallJobqueueUpdate :: RpcCallJobqueueUpdate -> JSValue
• toDictRpcCallJobqueueUpdate :: RpcCallJobqueueUpdate -> [(String, JSValue)]
• data RpcResultJobQueueUpdate = RpcResultJobQueueUpdate {
  }
• loadRpcResultJobQueueUpdate :: JSValue -> Result RpcResultJobQueueUpdate
• saveRpcResultJobQueueUpdate :: RpcResultJobQueueUpdate -> JSValue
• toDictRpcResultJobQueueUpdate :: RpcResultJobQueueUpdate -> [(String, JSValue)]
• data RpcCallJobqueueRename = RpcCallJobqueueRename {
  • rpcCallJobqueueRenameRename :: [(String, String)]
  }
• loadRpcCallJobqueueRename :: JSValue -> Result RpcCallJobqueueRename
• saveRpcCallJobqueueRename :: RpcCallJobqueueRename -> JSValue
• toDictRpcCallJobqueueRename :: RpcCallJobqueueRename -> [(String, JSValue)]
• data RpcResultJobqueueRename = RpcResultJobqueueRename {
  }
• loadRpcResultJobqueueRename :: JSValue -> Result RpcResultJobqueueRename
• saveRpcResultJobqueueRename :: RpcResultJobqueueRename -> JSValue
• toDictRpcResultJobqueueRename :: RpcResultJobqueueRename -> [(String, JSValue)]
• data RpcCallSetWatcherPause = RpcCallSetWatcherPause {
  • rpcCallSetWatcherPauseTime :: Maybe Double
  }
• loadRpcCallSetWatcherPause :: JSValue -> Result RpcCallSetWatcherPause
• saveRpcCallSetWatcherPause :: RpcCallSetWatcherPause -> JSValue
• toDictRpcCallSetWatcherPause :: RpcCallSetWatcherPause -> [(String, JSValue)]
• data RpcResultSetWatcherPause = RpcResultSetWatcherPause {
  }
• loadRpcResultSetWatcherPause :: JSValue -> Result RpcResultSetWatcherPause
• saveRpcResultSetWatcherPause :: RpcResultSetWatcherPause -> JSValue
• toDictRpcResultSetWatcherPause :: RpcResultSetWatcherPause -> [(String, JSValue)]
• data RpcCallSetDrainFlag = RpcCallSetDrainFlag {
  • rpcCallSetDrainFlagValue :: Bool
  }
• loadRpcCallSetDrainFlag :: JSValue -> Result RpcCallSetDrainFlag
• saveRpcCallSetDrainFlag :: RpcCallSetDrainFlag -> JSValue
• toDictRpcCallSetDrainFlag :: RpcCallSetDrainFlag -> [(String, JSValue)]
• data RpcResultSetDrainFlag = RpcResultSetDrainFlag {
  }
• loadRpcResultSetDrainFlag :: JSValue -> Result RpcResultSetDrainFlag
• saveRpcResultSetDrainFlag :: RpcResultSetDrainFlag -> JSValue
• toDictRpcResultSetDrainFlag :: RpcResultSetDrainFlag -> [(String, JSValue)]

Base RPC functionality and types

RPC calls and results

Instance info

AllInstancesInfo

InstanceConsoleInfo

InstanceList

NodeInfo

Version

StorageList

TestDelay

ExportList

Job Queue Replication

Watcher Status Update

Queue drain status