Synnefo » snf-ganeti

-- | Polls a set of jobs at a fixed interval until all are finished

-- one way or another.

waitForJobs client jids = do

  sts <- L.queryJobsStatus client jids

  case sts of

  , ResultStatus(..)

  , LuxiReq(..)

  , Client

  , checkRS

  , getClient

  , closeClient

-- * Generic protocol functionality

$(declareSADT "QrViaLuxi"

  [ ("QRLock", 'qrLock)

  , ("QRInstance", 'qrInstance)

  return rval

-- | Specialized submitManyJobs call.

submitManyJobs s jobs = do

  rval <- callMethod (SubmitManyJobs jobs) s

  -- map each result (status, payload) pair into a nice Result ADT

             x -> Bad ("Cannot parse response from Ganeti: " ++ show x)

-- | Custom queryJobs call.

queryJobsStatus s jids = do

  rval <- callMethod (QueryJobs (map read jids) ["status"]) s

  return $ case rval of