Synnefo » snf-ganeti

REQ_SUBMIT_JOB = "SubmitJob"

REQ_SUBMIT_JOB_TO_DRAINED_QUEUE = "SubmitJobToDrainedQueue"

REQ_SUBMIT_MANY_JOBS = "SubmitManyJobs"

REQ_WAIT_FOR_JOB_CHANGE = "WaitForJobChange"

REQ_CANCEL_JOB = "CancelJob"

REQ_ARCHIVE_JOB = "ArchiveJob"

  REQ_AUTO_ARCHIVE_JOBS,

  REQ_CANCEL_JOB,

  REQ_CHANGE_JOB_PRIORITY,

  REQ_QUERY,

  REQ_QUERY_CLUSTER_INFO,

  REQ_QUERY_CONFIG_VALUES,

  def SetWatcherPause(self, until):

    return self.CallMethod(REQ_SET_WATCHER_PAUSE, (until, ))

  def SubmitJob(self, ops):

    ops_state = map(lambda op: op.__getstate__(), ops)

    return self.CallMethod(REQ_SUBMIT_JOB, (ops_state, ))

      _LogNewJob(True, job_id, ops)

      return job_id

    elif method == luxi.REQ_SUBMIT_JOB_TO_DRAINED_QUEUE:

      logging.info("Forcefully receiving new job")

      (job_def, ) = args

     , simpleField "prev_log" [t| JSValue |]

     , simpleField "tmout"    [t| Int     |]

     ])

  , (luxiReqArchiveJob,

     [ simpleField "job" [t| JobId |] ]

    )

                    J.readJSON e

                  _ -> J.Error "Not enough values"

              return $ WaitForJobChange jid fields pinfo pidx wtmout

    ReqArchiveJob -> do

              [jid] <- fromJVal args

              return $ ArchiveJob jid

      Luxi.ReqWaitForJobChange -> Luxi.WaitForJobChange <$> arbitrary <*>

                                  genFields <*> pure J.JSNull <*>

                                  pure J.JSNull <*> arbitrary

      Luxi.ReqArchiveJob -> Luxi.ArchiveJob <$> arbitrary

      Luxi.ReqAutoArchiveJobs -> Luxi.AutoArchiveJobs <$> arbitrary <*>

                                 arbitrary

  luxi.REQ_ARCHIVE_JOB,

  luxi.REQ_AUTO_ARCHIVE_JOBS,

  luxi.REQ_CHANGE_JOB_PRIORITY,

  luxi.REQ_QUERY_EXPORTS,

  luxi.REQ_QUERY_CONFIG_VALUES,

  luxi.REQ_QUERY_NETWORKS,