ganeti.rpc.node._RpcProcessor

class documentation

class _RpcProcessor(object):

Undocumented

Method	`__call__`	Makes an RPC request to a number of nodes.
Method	`__init__`	Initializes this class.
Static Method	`_CombineResults`	Combines pre-computed results for offline hosts with actual call results.
Static Method	`_PrepareRequests`	Prepares requests by sorting offline hosts into separate list.
Instance Variable	`_lock_monitor_cb`	Undocumented
Instance Variable	`_port`	Undocumented
Instance Variable	`_resolver`	Undocumented

def __call__(self, nodes, procedure, body, read_timeout, resolver_opts, _req_process_fn=None): ¶

Makes an RPC request to a number of nodes.

Parameters
nodes:sequence	node UUIDs or Hostnames
procedure:string	Request path
body:dictionary	dictionary with request bodies per host
read_timeout:int or None	Read timeout for request
resolver_opts	Undocumented
_req_process_fn	Undocumented
Returns
dictionary	a dictionary mapping host names to rpc.RpcResult objects

def __init__(self, resolver, port, lock_monitor_cb=None): ¶

Initializes this class.

Parameters
resolver	callable accepting a list of node UUIDs or hostnames, returning a list of tuples containing name, IP address and original name of the resolved node. IP address can be the name or the special value `_OFFLINE` to mark offline machines.
port:int	TCP port
lock_monitor_cb	Callable for registering with lock monitor

@staticmethod
def _CombineResults(results, requests, procedure): ¶

Combines pre-computed results for offline hosts with actual call results.

@staticmethod
def _PrepareRequests(hosts, port, procedure, body, read_timeout): ¶

Prepares requests by sorting offline hosts into separate list.

Parameters
hosts	Undocumented
port	Undocumented
procedure	Undocumented
body:dict	a dictionary with per-host body data
read_timeout	Undocumented

_lock_monitor_cb = ¶

Undocumented

_port = ¶

Undocumented

_resolver = ¶

Undocumented