#else
--- | The curl options we use
+-- | The curl options we use.
curlOpts :: [CurlOption]
curlOpts = [ CurlSSLVerifyPeer False
, CurlSSLVerifyHost 0
getGroups body = loadJSArray "Parsing group data" body >>=
mapM (parseGroup . fromJSObject)
-getFakeGroups :: Result [(String, Group.Group)]
-getFakeGroups =
- return [(defaultGroupID,
- Group.create "default" defaultGroupID AllocPreferred)]
-
-- | Construct an instance from a JSON object.
parseInstance :: NameAssoc
-> JSRecord
running <- extract "status" a
tags <- extract "tags" a
auto_balance <- extract "auto_balance" beparams
+ dt <- extract "disk_template" a
let inst = Instance.create name mem disk vcpus running tags
- auto_balance pnode snode
+ auto_balance pnode snode dt
return (name, inst)
-- | Construct a node from a JSON object.
tags_body <- getUrl $ printf "%s/2/tags" url
return (group_body, node_body, inst_body, tags_body)
--- | Builds the cluster data from the raw Rapi content
+-- | Builds the cluster data from the raw Rapi content.
parseData :: (Result String, Result String, Result String, Result String)
-> Result ClusterData
parseData (group_body, node_body, inst_body, tags_body) = do
- group_data <-
- -- TODO: handle different ganeti versions properly, not via "all
- -- errors mean Ganeti 2.3"
- case group_body of
- Bad _ -> getFakeGroups
- Ok v -> getGroups v
+ group_data <- group_body >>= getGroups
let (group_names, group_idx) = assignIndices group_data
node_data <- node_body >>= getNodes group_names
let (node_names, node_idx) = assignIndices node_data
tags_data <- tags_body >>= (fromJResult "Parsing tags data" . decodeStrict)
return (ClusterData group_idx node_idx inst_idx tags_data)
--- | Top level function for data loading
+-- | Top level function for data loading.
loadData :: String -- ^ Cluster or URL to use as source
-> IO (Result ClusterData)
loadData = fmap parseData . readData