| Safe Haskell | Safe-Inferred |
|---|---|
| Language | Haskell2010 |
Ganeti.Rpc
Description
Implementation of the RPC client.
Synopsis
- class ArrayObject a => RpcCall a
- class (RpcCall a, JSON b) => Rpc a b | a -> b, b -> a
- data RpcError
- = CurlLayerError String
- | JsonDecodeError String
- | RpcResultError String
- | OfflineNodeError
- type ERpcError = Either RpcError
- explainRpcError :: RpcError -> String
- executeRpcCall :: Rpc a b => [Node] -> a -> IO [(Node, ERpcError b)]
- executeRpcCalls :: Rpc a b => [(Node, a)] -> IO [(Node, ERpcError b)]
- rpcErrors :: [(a, ERpcError b)] -> [(a, RpcError)]
- logRpcErrors :: (MonadLog m, Show a) => [(a, ERpcError b)] -> m [(a, RpcError)]
- rpcCallName :: RpcCall a => a -> String
- rpcCallTimeout :: RpcCall a => a -> Int
- rpcCallData :: RpcCall a => a -> String
- rpcCallAcceptOffline :: RpcCall a => a -> Bool
- rpcResultFill :: Rpc a b => a -> JSValue -> ERpcError b
- data Compressed
- packCompressed :: ByteString -> Compressed
- toCompressed :: String -> Compressed
- getCompressed :: Compressed -> ByteString
- data RpcCallNodeActivateMasterIp = RpcCallNodeActivateMasterIp {}
- data RpcResultNodeActivateMasterIp = RpcResultNodeActivateMasterIp {
- data RpcCallInstanceInfo = RpcCallInstanceInfo {
- rpcCallInstInfoInstance :: String
- rpcCallInstInfoHname :: Hypervisor
- data InstanceState
- data InstanceInfo = InstanceInfo {
- instInfoMemory :: Int
- instInfoState :: InstanceState
- instInfoVcpus :: Int
- instInfoTime :: Int
- data RpcResultInstanceInfo = RpcResultInstanceInfo {
- rpcResInstInfoInstInfo :: (Maybe InstanceInfo)
- data RpcCallAllInstancesInfo = RpcCallAllInstancesInfo {}
- data RpcResultAllInstancesInfo = RpcResultAllInstancesInfo {
- rpcResAllInstInfoInstances :: [(String, InstanceInfo)]
- data InstanceConsoleInfoParams = InstanceConsoleInfoParams {}
- 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)
- data RpcCallInstanceConsoleInfo = RpcCallInstanceConsoleInfo {
- rpcCallInstConsInfoInstanceInfo :: [(String, InstanceConsoleInfoParams)]
- data RpcResultInstanceConsoleInfo = RpcResultInstanceConsoleInfo {
- rpcResInstConsInfoInstancesInfo :: [(String, InstanceConsoleInfo)]
- data RpcCallInstanceList = RpcCallInstanceList {}
- data RpcResultInstanceList = RpcResultInstanceList {
- rpcResInstListInstances :: [String]
- data HvInfo = HvInfo {
- hvInfoHvVersion :: (Maybe [Int])
- hvInfoMemoryTotal :: Int
- hvInfoMemoryFree :: Int
- hvInfoMemoryDom0 :: Int
- hvInfoMemoryHv :: (Maybe Int)
- hvInfoCpuTotal :: Int
- hvInfoCpuNodes :: Int
- hvInfoCpuSockets :: Int
- hvInfoCpuDom0 :: Int
- data StorageInfo = StorageInfo {
- storageInfoName :: String
- storageInfoType :: String
- storageInfoStorageFree :: (Maybe Int)
- storageInfoStorageSize :: (Maybe Int)
- data RpcCallNodeInfo = RpcCallNodeInfo {}
- data RpcResultNodeInfo = RpcResultNodeInfo {
- rpcResNodeInfoBootId :: String
- rpcResNodeInfoStorageInfo :: [StorageInfo]
- rpcResNodeInfoHvInfo :: [HvInfo]
- data RpcCallVersion = RpcCallVersion {
- data RpcResultVersion = RpcResultVersion {
- rpcResultVersionVersion :: Int
- data RpcCallMasterNodeName = RpcCallMasterNodeName {
- data RpcResultMasterNodeName = RpcResultMasterNodeName {
- rpcResultMasterNodeNameMaster :: String
- data RpcCallStorageList = RpcCallStorageList {
- rpcCallStorageListSuName :: StorageType
- rpcCallStorageListSuArgs :: [String]
- rpcCallStorageListName :: String
- rpcCallStorageListFields :: [StorageField]
- data RpcResultStorageList = RpcResultStorageList {
- rpcResStorageListStorage :: [[(StorageField, JSValue)]]
- data RpcCallTestDelay = RpcCallTestDelay {
- rpcCallTestDelayDuration :: Double
- data RpcResultTestDelay = RpcResultTestDelay
- data RpcCallExportList = RpcCallExportList {
- data RpcResultExportList = RpcResultExportList {
- rpcResExportListExports :: [String]
- data RpcCallJobqueueUpdate = RpcCallJobqueueUpdate {
- rpcCallJobqueueUpdateFileName :: String
- rpcCallJobqueueUpdateContent :: String
- data RpcCallJobqueueRename = RpcCallJobqueueRename {
- rpcCallJobqueueRenameRename :: [(String, String)]
- data RpcCallSetWatcherPause = RpcCallSetWatcherPause {
- rpcCallSetWatcherPauseTime :: (Maybe ClockTime)
- data RpcCallSetDrainFlag = RpcCallSetDrainFlag {
- rpcCallSetDrainFlagValue :: Bool
- data RpcCallUploadFile = RpcCallUploadFile {
- rpcCallUploadFileFileName :: FilePath
- rpcCallUploadFileContent :: Compressed
- rpcCallUploadFileMode :: (Maybe FileMode)
- rpcCallUploadFileUid :: String
- rpcCallUploadFileGid :: String
- rpcCallUploadFileAtime :: ClockTime
- rpcCallUploadFileMtime :: ClockTime
- prepareRpcCallUploadFile :: RuntimeEnts -> FilePath -> ResultG RpcCallUploadFile
- data RpcCallWriteSsconfFiles = RpcCallWriteSsconfFiles {}
Documentation
class ArrayObject a => RpcCall a #
A generic class for RPC calls.
Minimal complete definition
Instances
class (RpcCall a, JSON b) => Rpc a b | a -> b, b -> a #
Generic class that ensures matching RPC call with its respective result.
Minimal complete definition
Instances
Data type for RPC error reporting.
Constructors
| CurlLayerError String | |
| JsonDecodeError String | |
| RpcResultError String | |
| OfflineNodeError |
explainRpcError :: RpcError -> String #
Provide explanation to RPC errors.
executeRpcCall :: Rpc a b => [Node] -> a -> IO [(Node, ERpcError b)] #
Execute an RPC call for many nodes in parallel. NB this computes the RPC call payload string only once.
executeRpcCalls :: Rpc a b => [(Node, a)] -> IO [(Node, ERpcError b)] #
Execute multiple distinct RPC calls in parallel
rpcErrors :: [(a, ERpcError b)] -> [(a, RpcError)] #
Scan the list of results produced by executeRpcCall and extract all the RPC errors.
logRpcErrors :: (MonadLog m, Show a) => [(a, ERpcError b)] -> m [(a, RpcError)] #
Scan the list of results produced by executeRpcCall and log all the RPC errors. Returns the list of errors for further processing.
rpcCallName :: RpcCall a => a -> String #
Give the (Python) name of the procedure.
rpcCallTimeout :: RpcCall a => a -> Int #
Calculate the timeout value for the call execution.
rpcCallData :: RpcCall a => a -> String #
Prepare arguments of the call to be send as POST.
rpcCallAcceptOffline :: RpcCall a => a -> Bool #
Whether we accept offline nodes when making a call.
rpcResultFill :: Rpc a b => a -> JSValue -> ERpcError b #
Create a result based on the received HTTP response.
data Compressed #
An opaque data type for representing data that might be compressed over the wire.
On Python side it is decompressed by backend._Decompress.
Instances
| Show Compressed # | |
Defined in Ganeti.Rpc Methods showsPrec :: Int -> Compressed -> ShowS show :: Compressed -> String showList :: [Compressed] -> ShowS | |
| Eq Compressed # | |
Defined in Ganeti.Rpc | |
| Ord Compressed # | |
Defined in Ganeti.Rpc Methods compare :: Compressed -> Compressed -> Ordering (<) :: Compressed -> Compressed -> Bool (<=) :: Compressed -> Compressed -> Bool (>) :: Compressed -> Compressed -> Bool (>=) :: Compressed -> Compressed -> Bool max :: Compressed -> Compressed -> Compressed min :: Compressed -> Compressed -> Compressed | |
| JSON Compressed # | |
Defined in Ganeti.Rpc Methods readJSON :: JSValue -> Result Compressed showJSON :: Compressed -> JSValue readJSONs :: JSValue -> Result [Compressed] showJSONs :: [Compressed] -> JSValue | |
packCompressed :: ByteString -> Compressed #
toCompressed :: String -> Compressed #
getCompressed :: Compressed -> ByteString #
data RpcCallNodeActivateMasterIp #
Activate the master IP address
Constructors
| RpcCallNodeActivateMasterIp | |
Instances
data RpcResultNodeActivateMasterIp #
Constructors
| RpcResultNodeActivateMasterIp | |
Instances
data RpcCallInstanceInfo #
Returns information about a single instance
Constructors
| RpcCallInstanceInfo | |
Fields
| |
Instances
data InstanceState #
Constructors
| InstanceStateRunning | |
| InstanceStateShutdown |
Instances
data InstanceInfo #
Constructors
| InstanceInfo | |
Fields
| |
Instances
| Show InstanceInfo # | |
Defined in Ganeti.Rpc Methods showsPrec :: Int -> InstanceInfo -> ShowS show :: InstanceInfo -> String showList :: [InstanceInfo] -> ShowS | |
| ArrayObject InstanceInfo # | |
Defined in Ganeti.Rpc | |
| DictObject InstanceInfo # | |
Defined in Ganeti.Rpc Methods toDict :: InstanceInfo -> [(String, JSValue)] # fromDictWKeys :: [(String, JSValue)] -> WriterT UsedKeys Result InstanceInfo # fromDict :: [(String, JSValue)] -> Result InstanceInfo # | |
| Eq InstanceInfo # | |
Defined in Ganeti.Rpc | |
| JSON InstanceInfo # | |
Defined in Ganeti.Rpc Methods readJSON :: JSValue -> Result InstanceInfo showJSON :: InstanceInfo -> JSValue readJSONs :: JSValue -> Result [InstanceInfo] showJSONs :: [InstanceInfo] -> JSValue | |
data RpcResultInstanceInfo #
Constructors
| RpcResultInstanceInfo | |
Fields
| |
Instances
data RpcCallAllInstancesInfo #
Returns information about all running instances on the given nodes
Constructors
| RpcCallAllInstancesInfo | |
Fields | |
Instances
data RpcResultAllInstancesInfo #
Constructors
| RpcResultAllInstancesInfo | |
Fields
| |
Instances
data InstanceConsoleInfoParams #
Returns information about how to access instances on the given node
Constructors
| InstanceConsoleInfoParams | |
Instances
data InstanceConsoleInfo #
Constructors
| InstanceConsoleInfo | |
Fields
| |
Instances
data RpcCallInstanceConsoleInfo #
Constructors
| RpcCallInstanceConsoleInfo | |
Fields
| |
Instances
data RpcResultInstanceConsoleInfo #
Constructors
| RpcResultInstanceConsoleInfo | |
Fields
| |
Instances
data RpcCallInstanceList #
Returns the list of running instances on the given nodes
Constructors
| RpcCallInstanceList | |
Fields | |
Instances
data RpcResultInstanceList #
Constructors
| RpcResultInstanceList | |
Fields
| |
Instances
Common fields (as described in hv_base.py) are mandatory, other fields are optional.
Constructors
| HvInfo | |
Fields
| |
Instances
| Show HvInfo # | |
| ArrayObject HvInfo # | |
Defined in Ganeti.Rpc | |
| DictObject HvInfo # | |
Defined in Ganeti.Rpc | |
| Eq HvInfo # | |
| JSON HvInfo # | |
data StorageInfo #
Constructors
| StorageInfo | |
Fields
| |
Instances
| Show StorageInfo # | |
Defined in Ganeti.Rpc Methods showsPrec :: Int -> StorageInfo -> ShowS show :: StorageInfo -> String showList :: [StorageInfo] -> ShowS | |
| ArrayObject StorageInfo # | |
Defined in Ganeti.Rpc | |
| DictObject StorageInfo # | |
Defined in Ganeti.Rpc Methods toDict :: StorageInfo -> [(String, JSValue)] # fromDictWKeys :: [(String, JSValue)] -> WriterT UsedKeys Result StorageInfo # fromDict :: [(String, JSValue)] -> Result StorageInfo # | |
| Eq StorageInfo # | |
Defined in Ganeti.Rpc | |
| JSON StorageInfo # | |
Defined in Ganeti.Rpc Methods readJSON :: JSValue -> Result StorageInfo showJSON :: StorageInfo -> JSValue readJSONs :: JSValue -> Result [StorageInfo] showJSONs :: [StorageInfo] -> JSValue | |
data RpcCallNodeInfo #
Returns node information
Constructors
| RpcCallNodeInfo | |
Fields | |
Instances
data RpcResultNodeInfo #
Constructors
| RpcResultNodeInfo | |
Fields
| |
Instances
data RpcCallVersion #
Query node version.
Constructors
| RpcCallVersion | |
Instances
data RpcResultVersion #
Query node reply.
Constructors
| RpcResultVersion | |
Fields
| |
Instances
data RpcCallMasterNodeName #
Ask who the node believes is the master.
Constructors
| RpcCallMasterNodeName | |
Instances
data RpcResultMasterNodeName #
Constructors
| RpcResultMasterNodeName | |
Fields
| |
Instances
data RpcCallStorageList #
Constructors
| RpcCallStorageList | |
Fields
| |
Instances
data RpcResultStorageList #
Constructors
| RpcResultStorageList | |
Fields
| |
Instances
data RpcCallTestDelay #
Call definition for test delay.
Constructors
| RpcCallTestDelay | |
Fields
| |
Instances
data RpcResultTestDelay #
Result definition for test delay.
Constructors
| RpcResultTestDelay |
Instances
| Show RpcResultTestDelay # | |
Defined in Ganeti.Rpc Methods showsPrec :: Int -> RpcResultTestDelay -> ShowS show :: RpcResultTestDelay -> String showList :: [RpcResultTestDelay] -> ShowS | |
| JSON RpcResultTestDelay # | Custom JSON instance for null result. |
Defined in Ganeti.Rpc Methods readJSON :: JSValue -> Result RpcResultTestDelay showJSON :: RpcResultTestDelay -> JSValue readJSONs :: JSValue -> Result [RpcResultTestDelay] showJSONs :: [RpcResultTestDelay] -> JSValue | |
| Rpc RpcCallTestDelay RpcResultTestDelay # | |
Defined in Ganeti.Rpc Methods rpcResultFill :: RpcCallTestDelay -> JSValue -> ERpcError RpcResultTestDelay # | |
data RpcCallExportList #
Call definition for export list.
Constructors
| RpcCallExportList | |
Instances
data RpcResultExportList #
Result definition for export list.
Constructors
| RpcResultExportList | |
Fields
| |
Instances
data RpcCallJobqueueUpdate #
Update a job queue file
Constructors
| RpcCallJobqueueUpdate | |
Fields
| |
Instances
data RpcCallJobqueueRename #
Rename a file in the job queue
Constructors
| RpcCallJobqueueRename | |
Fields
| |
Instances
data RpcCallSetWatcherPause #
Set the watcher status
Constructors
| RpcCallSetWatcherPause | |
Fields
| |
Instances
data RpcCallSetDrainFlag #
Set the queu drain flag
Constructors
| RpcCallSetDrainFlag | |
Fields
| |
Instances
data RpcCallUploadFile #
Upload a configuration file to nodes
Constructors
| RpcCallUploadFile | |
Fields
| |
Instances
prepareRpcCallUploadFile :: RuntimeEnts -> FilePath -> ResultG RpcCallUploadFile #
Reads a file and constructs the corresponding RpcCallUploadFile value.
data RpcCallWriteSsconfFiles #
Upload ssconf files to nodes
Constructors
| RpcCallWriteSsconfFiles | |
Fields | |