Synnefo » snf-ganeti » ganeti-local

import Ganeti.HTools.Types

import qualified Ganeti.HTools.Node as Node

import qualified Ganeti.HTools.Instance as Instance

-- * Utility functions

        use_locking = JSBool False

    in JSArray [nnames, fields, use_locking]

-- | Wraper over callMethod doing node query.

queryNodes :: L.Client -> IO (Result JSValue)

queryNodes = L.callMethod L.QueryNodes queryNodesMsg

queryInstances :: L.Client -> IO (Result JSValue)

queryInstances = L.callMethod L.QueryInstances queryInstancesMsg

-- | Parse a instance list in JSON format.

getInstances :: NameAssoc

             -> JSValue

parseNode v = fail ("Invalid node query result: " ++ show v)

-- * Main loader functionality

-- | Builds the cluster data from an URL.

       (\s -> do

          nodes <- queryNodes s

          instances <- queryInstances s

          return $ do -- Result monad

            node_data <- nodes >>= getNodes

            let (node_names, node_idx) = assignIndices node_data

            inst_data <- instances >>= getInstances node_names

            let (_, inst_idx) = assignIndices inst_data

       )

data LuxiOp = QueryInstances

            | QueryNodes

            | QueryJobs

            | SubmitManyJobs

-- | The serialisation of LuxiOps into strings in messages.

strOfOp QueryNodes = "QueryNodes"

strOfOp QueryInstances = "QueryInstances"

strOfOp QueryJobs = "QueryJobs"

strOfOp SubmitManyJobs = "SubmitManyJobs"

-- | The end-of-message separator.