class documentation

class RpcClientJobQueue(object):

Known subclasses: ganeti.rpc.node.JobQueueRunner

View In Hierarchy

Undocumented

Method call_jobqueue_purge Wrapper for RPC call 'jobqueue_purge'
Method call_jobqueue_rename Wrapper for RPC call 'jobqueue_rename'
Method call_jobqueue_set_drain_flag Wrapper for RPC call 'jobqueue_set_drain_flag'
Method call_jobqueue_update Wrapper for RPC call 'jobqueue_update'
Constant _CALLS Undocumented
def call_jobqueue_purge(self, node, _def=_CALLS['jobqueue_purge']):

Wrapper for RPC call 'jobqueue_purge'

Purge job queue

Parameters
node:stringNode name
_defUndocumented
Note
This is a single-node call with a timeout of 15m 0s
def call_jobqueue_rename(self, node_list, rename, _def=_CALLS['jobqueue_rename']):

Wrapper for RPC call 'jobqueue_rename'

Rename job queue file

Parameters
node_list:list of stringList of node names
renameUndocumented
_defUndocumented
Note
This is a multi-node call with a timeout of 1m 0s
def call_jobqueue_set_drain_flag(self, node_list, flag, _def=_CALLS['jobqueue_set_drain_flag']):

Wrapper for RPC call 'jobqueue_set_drain_flag'

Set job queue drain flag

Parameters
node_list:list of stringList of node names
flagUndocumented
_defUndocumented
Note
This is a multi-node call with a timeout of 1m 0s
def call_jobqueue_update(self, node_list, file_name, content, _def=_CALLS['jobqueue_update']):

Wrapper for RPC call 'jobqueue_update'

Update job queue file

Parameters
node_list:list of stringList of node names
file_nameUndocumented
contentUndocumented
_defUndocumented
Note
This is a multi-node call with a timeout of 1m 0s
_CALLS =

Undocumented

Value
rpc_defs.CALLS['RpcClientJobQueue']