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
  • Configuration files upload to nodes

Description

Synopsis

• curlOpts :: [CurlOption]
• data RpcError
  • = CurlLayerError String
  • | JsonDecodeError String
  • | RpcResultError String
  • | OfflineNodeError
• explainRpcError :: RpcError -> String
• type ERpcError = Either RpcError
• class ArrayObject 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 => Int -> Node -> a -> String
• prepareHttpRequest :: RpcCall a => Int -> [CurlOption] -> Node -> a -> ERpcError HttpClientRequest
• parseHttpReply :: Rpc a b => a -> ERpcError (CurlCode, String) -> ERpcError b
• parseHttpResponse :: Rpc a b => a -> String -> ERpcError b
• rpcErrors :: [(a, ERpcError b)] -> [(a, RpcError)]
• logRpcErrors :: (MonadLog m, Show a) => [(a, ERpcError b)] -> m [(a, RpcError)]
• getOptionsForCall :: Rpc a b => FilePath -> FilePath -> a -> [CurlOption]
• getNodedPort :: IO Int
• 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
• newtype Compressed = Compressed {
  • getCompressed :: ByteString
  }
• packCompressed :: ByteString -> Compressed
• toCompressed :: String -> Compressed
• data RpcCallInstanceInfo = RpcCallInstanceInfo {
  • rpcCallInstInfoInstance :: String
  • rpcCallInstInfoHname :: Hypervisor
  }
• loadRpcCallInstanceInfo :: JSValue -> Result RpcCallInstanceInfo
• saveRpcCallInstanceInfo :: RpcCallInstanceInfo -> 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
• data RpcResultInstanceInfo = RpcResultInstanceInfo {
  • rpcResInstInfoInstInfo :: Maybe InstanceInfo
  }
• loadRpcResultInstanceInfo :: JSValue -> Result RpcResultInstanceInfo
• saveRpcResultInstanceInfo :: RpcResultInstanceInfo -> JSValue
• data RpcCallAllInstancesInfo = RpcCallAllInstancesInfo {
  • rpcCallAllInstInfoHypervisors :: [(Hypervisor, HvParams)]
  }
• loadRpcCallAllInstancesInfo :: JSValue -> Result RpcCallAllInstancesInfo
• saveRpcCallAllInstancesInfo :: RpcCallAllInstancesInfo -> JSValue
• data RpcResultAllInstancesInfo = RpcResultAllInstancesInfo {
  • rpcResAllInstInfoInstances :: [(String, InstanceInfo)]
  }
• loadRpcResultAllInstancesInfo :: JSValue -> Result RpcResultAllInstancesInfo
• saveRpcResultAllInstancesInfo :: RpcResultAllInstancesInfo -> JSValue
• data InstanceConsoleInfoParams = InstanceConsoleInfoParams {
  • instConsInfoParamsInstance :: Instance
  • instConsInfoParamsNode :: Node
  • instConsInfoParamsGroup :: NodeGroup
  • instConsInfoParamsHvParams :: HvParams
  • instConsInfoParamsBeParams :: FilledBeParams
  }
• loadInstanceConsoleInfoParams :: JSValue -> Result InstanceConsoleInfoParams
• saveInstanceConsoleInfoParams :: InstanceConsoleInfoParams -> JSValue
• data RpcCallInstanceConsoleInfo = RpcCallInstanceConsoleInfo {
  • rpcCallInstConsInfoInstanceInfo :: [(String, InstanceConsoleInfoParams)]
  }
• loadRpcCallInstanceConsoleInfo :: JSValue -> Result RpcCallInstanceConsoleInfo
• saveRpcCallInstanceConsoleInfo :: RpcCallInstanceConsoleInfo -> 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
• data RpcResultInstanceConsoleInfo = RpcResultInstanceConsoleInfo {
  • rpcResInstConsInfoInstancesInfo :: [(String, InstanceConsoleInfo)]
  }
• loadRpcResultInstanceConsoleInfo :: JSValue -> Result RpcResultInstanceConsoleInfo
• saveRpcResultInstanceConsoleInfo :: RpcResultInstanceConsoleInfo -> JSValue
• data RpcCallInstanceList = RpcCallInstanceList {
  • rpcCallInstListHypervisors :: [Hypervisor]
  }
• loadRpcCallInstanceList :: JSValue -> Result RpcCallInstanceList
• saveRpcCallInstanceList :: RpcCallInstanceList -> JSValue
• data RpcResultInstanceList = RpcResultInstanceList {
  • rpcResInstListInstances :: [String]
  }
• loadRpcResultInstanceList :: JSValue -> Result RpcResultInstanceList
• saveRpcResultInstanceList :: RpcResultInstanceList -> JSValue
• data RpcCallNodeInfo = RpcCallNodeInfo {
  • rpcCallNodeInfoStorageUnits :: Map String [StorageUnit]
  • rpcCallNodeInfoHypervisors :: [(Hypervisor, HvParams)]
  }
• loadRpcCallNodeInfo :: JSValue -> Result RpcCallNodeInfo
• saveRpcCallNodeInfo :: RpcCallNodeInfo -> JSValue
• data StorageInfo = StorageInfo {
  • storageInfoName :: String
  • storageInfoType :: String
  • storageInfoStorageFree :: Maybe Int
  • storageInfoStorageSize :: Maybe Int
  }
• loadStorageInfo :: JSValue -> Result StorageInfo
• saveStorageInfo :: StorageInfo -> JSValue
• data HvInfo = HvInfo {
  • hvInfoHvVersion :: Maybe [Int]
  • hvInfoMemoryTotal :: Int
  • hvInfoMemoryFree :: Int
  • hvInfoMemoryDom0 :: Int
  • hvInfoMemoryHv :: Maybe Int
  • hvInfoCpuTotal :: Int
  • hvInfoCpuNodes :: Int
  • hvInfoCpuSockets :: Int
  • hvInfoCpuDom0 :: Int
  }
• loadHvInfo :: JSValue -> Result HvInfo
• saveHvInfo :: HvInfo -> JSValue
• data RpcResultNodeInfo = RpcResultNodeInfo {
  • rpcResNodeInfoBootId :: String
  • rpcResNodeInfoStorageInfo :: [StorageInfo]
  • rpcResNodeInfoHvInfo :: [HvInfo]
  }
• loadRpcResultNodeInfo :: JSValue -> Result RpcResultNodeInfo
• saveRpcResultNodeInfo :: RpcResultNodeInfo -> JSValue
• data RpcCallVersion = RpcCallVersion {
  }
• loadRpcCallVersion :: JSValue -> Result RpcCallVersion
• saveRpcCallVersion :: RpcCallVersion -> JSValue
• data RpcResultVersion = RpcResultVersion {
  • rpcResultVersionVersion :: Int
  }
• loadRpcResultVersion :: JSValue -> Result RpcResultVersion
• saveRpcResultVersion :: RpcResultVersion -> JSValue
• data RpcCallStorageList = RpcCallStorageList {
  • rpcCallStorageListSuName :: StorageType
  • rpcCallStorageListSuArgs :: [String]
  • rpcCallStorageListName :: String
  • rpcCallStorageListFields :: [StorageField]
  }
• loadRpcCallStorageList :: JSValue -> Result RpcCallStorageList
• saveRpcCallStorageList :: RpcCallStorageList -> JSValue
• data RpcResultStorageList = RpcResultStorageList {
  • rpcResStorageListStorage :: [[(StorageField, JSValue)]]
  }
• loadRpcResultStorageList :: JSValue -> Result RpcResultStorageList
• saveRpcResultStorageList :: RpcResultStorageList -> JSValue
• data RpcCallTestDelay = RpcCallTestDelay {
  • rpcCallTestDelayDuration :: Double
  }
• loadRpcCallTestDelay :: JSValue -> Result RpcCallTestDelay
• saveRpcCallTestDelay :: RpcCallTestDelay -> JSValue
• data RpcResultTestDelay = RpcResultTestDelay
• data RpcCallExportList = RpcCallExportList {
  }
• loadRpcCallExportList :: JSValue -> Result RpcCallExportList
• saveRpcCallExportList :: RpcCallExportList -> JSValue
• data RpcResultExportList = RpcResultExportList {
  • rpcResExportListExports :: [String]
  }
• loadRpcResultExportList :: JSValue -> Result RpcResultExportList
• saveRpcResultExportList :: RpcResultExportList -> JSValue
• data RpcCallJobqueueUpdate = RpcCallJobqueueUpdate {
  • rpcCallJobqueueUpdateFileName :: String
  • rpcCallJobqueueUpdateContent :: String
  }
• loadRpcCallJobqueueUpdate :: JSValue -> Result RpcCallJobqueueUpdate
• saveRpcCallJobqueueUpdate :: RpcCallJobqueueUpdate -> JSValue
• data RpcResultJobQueueUpdate = RpcResultJobQueueUpdate {
  }
• loadRpcResultJobQueueUpdate :: JSValue -> Result RpcResultJobQueueUpdate
• saveRpcResultJobQueueUpdate :: RpcResultJobQueueUpdate -> JSValue
• data RpcCallJobqueueRename = RpcCallJobqueueRename {
  • rpcCallJobqueueRenameRename :: [(String, String)]
  }
• loadRpcCallJobqueueRename :: JSValue -> Result RpcCallJobqueueRename
• saveRpcCallJobqueueRename :: RpcCallJobqueueRename -> JSValue
• data RpcResultJobqueueRename = RpcResultJobqueueRename {
  }
• loadRpcResultJobqueueRename :: JSValue -> Result RpcResultJobqueueRename
• saveRpcResultJobqueueRename :: RpcResultJobqueueRename -> JSValue
• data RpcCallSetWatcherPause = RpcCallSetWatcherPause {
  • rpcCallSetWatcherPauseTime :: Maybe ClockTime
  }
• loadRpcCallSetWatcherPause :: JSValue -> Result RpcCallSetWatcherPause
• saveRpcCallSetWatcherPause :: RpcCallSetWatcherPause -> JSValue
• data RpcResultSetWatcherPause = RpcResultSetWatcherPause {
  }
• loadRpcResultSetWatcherPause :: JSValue -> Result RpcResultSetWatcherPause
• saveRpcResultSetWatcherPause :: RpcResultSetWatcherPause -> JSValue
• data RpcCallSetDrainFlag = RpcCallSetDrainFlag {
  • rpcCallSetDrainFlagValue :: Bool
  }
• loadRpcCallSetDrainFlag :: JSValue -> Result RpcCallSetDrainFlag
• saveRpcCallSetDrainFlag :: RpcCallSetDrainFlag -> JSValue
• data RpcResultSetDrainFlag = RpcResultSetDrainFlag {
  }
• loadRpcResultSetDrainFlag :: JSValue -> Result RpcResultSetDrainFlag
• saveRpcResultSetDrainFlag :: RpcResultSetDrainFlag -> JSValue
• data RpcCallUploadFile = RpcCallUploadFile {
  • rpcCallUploadFileFileName :: FilePath
  • rpcCallUploadFileContent :: Compressed
  • rpcCallUploadFileMode :: Maybe FileMode
  • rpcCallUploadFileUid :: String
  • rpcCallUploadFileGid :: String
  • rpcCallUploadFileAtime :: ClockTime
  • rpcCallUploadFileMtime :: ClockTime
  }
• loadRpcCallUploadFile :: JSValue -> Result RpcCallUploadFile
• saveRpcCallUploadFile :: RpcCallUploadFile -> JSValue
• data RpcResultUploadFile = RpcResultUploadFile {
  }
• loadRpcResultUploadFile :: JSValue -> Result RpcResultUploadFile
• saveRpcResultUploadFile :: RpcResultUploadFile -> JSValue
• prepareRpcCallUploadFile :: RuntimeEnts -> FilePath -> ResultG RpcCallUploadFile
• data RpcCallWriteSsconfFiles = RpcCallWriteSsconfFiles {
  • rpcCallWriteSsconfFilesValues :: SSConf
  }
• loadRpcCallWriteSsconfFiles :: JSValue -> Result RpcCallWriteSsconfFiles
• saveRpcCallWriteSsconfFiles :: RpcCallWriteSsconfFiles -> JSValue
• data RpcResultWriteSsconfFiles = RpcResultWriteSsconfFiles {
  }
• loadRpcResultWriteSsconfFiles :: JSValue -> Result RpcResultWriteSsconfFiles
• saveRpcResultWriteSsconfFiles :: RpcResultWriteSsconfFiles -> JSValue
• data RpcCallNodeActivateMasterIp = RpcCallNodeActivateMasterIp {
  • rpcCallNodeActivateMasterIpParams :: MasterNetworkParameters
  • rpcCallNodeActivateMasterIpEms :: Bool
  }
• loadRpcCallNodeActivateMasterIp :: JSValue -> Result RpcCallNodeActivateMasterIp
• saveRpcCallNodeActivateMasterIp :: RpcCallNodeActivateMasterIp -> JSValue
• data RpcResultNodeActivateMasterIp = RpcResultNodeActivateMasterIp {
  }
• loadRpcResultNodeActivateMasterIp :: JSValue -> Result RpcResultNodeActivateMasterIp
• saveRpcResultNodeActivateMasterIp :: RpcResultNodeActivateMasterIp -> JSValue
• data RpcCallMasterNodeName = RpcCallMasterNodeName {
  }
• loadRpcCallMasterNodeName :: JSValue -> Result RpcCallMasterNodeName
• saveRpcCallMasterNodeName :: RpcCallMasterNodeName -> JSValue
• data RpcResultMasterNodeName = RpcResultMasterNodeName {
  • rpcResultMasterNodeNameMaster :: String
  }
• loadRpcResultMasterNodeName :: JSValue -> Result RpcResultMasterNodeName
• saveRpcResultMasterNodeName :: RpcResultMasterNodeName -> 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

Configuration files upload to nodes