Package ganeti :: Module rpc_defs
[hide private]
[frames] | no frames]

Module rpc_defs

source code

RPC definitions for communication between master and node daemons.

RPC definition fields:

Functions [hide private]
 
_Prepare(calls)
Converts list of calls to dictionary.
source code
 
_MigrationStatusPostProc(result)
Post-processor for rpc.RpcRunner.call_instance_get_migration_status.
source code
 
_BlockdevFindPostProc(result)
Post-processor for rpc.RpcRunner.call_blockdev_find.
source code
 
_BlockdevGetMirrorStatusPostProc(result)
Post-processor for rpc.RpcRunner.call_blockdev_getmirrorstatus.
source code
 
_BlockdevGetMirrorStatusMultiPreProc(node, args)
Prepares the appropriate node values for blockdev_getmirrorstatus_multi.
source code
 
_BlockdevGetMirrorStatusMultiPostProc(result)
Post-processor for rpc.RpcRunner.call_blockdev_getmirrorstatus_multi.
source code
 
_NodeInfoPreProc(node, args)
Prepare the exclusive_storage argument for node_info calls.
source code
 
_OsGetPostProc(result)
Post-processor for rpc.RpcRunner.call_os_get.
source code
Payload containing list of objects.ImportExportStatus instances
_ImpExpStatusPostProc(result)
Post-processor for import/export status.
source code
 
_TestDelayTimeout((duration,))
Calculate timeout for "test_delay" RPC.
source code
Variables [hide private]
  SINGLE = "single-node"
  MULTI = "multi-node"
  ACCEPT_OFFLINE_NODE = object()
  _FILE_STORAGE_CALLS = [("file_storage_dir_create", SINGLE, Non...
  _STORAGE_CALLS = [("storage_list", MULTI, None, constants.RPC_...
  _INSTANCE_CALLS = [("instance_info", SINGLE, None, constants.R...
  _IMPEXP_CALLS = [("import_start", SINGLE, None, constants.RPC_...
  _X509_CALLS = [("x509_cert_create", SINGLE, None, constants.RP...
  _BLOCKDEV_CALLS = [("bdev_sizes", MULTI, None, constants.RPC_T...
  _OS_CALLS = [("os_diagnose", MULTI, None, constants.RPC_TMO_FA...
  _EXTSTORAGE_CALLS = [("extstorage_diagnose", MULTI, None, cons...
  _NODE_CALLS = [("node_has_ip_address", SINGLE, None, constants...
  _MISC_CALLS = [("lv_list", MULTI, None, constants.RPC_TMO_URGE...
  CALLS = {"RpcClientDefault": _Prepare(_IMPEXP_CALLS+ _X509_CAL...

Imports: constants, utils, objects


Function Details [hide private]

_ImpExpStatusPostProc(result)

source code 

Post-processor for import/export status.

Returns: Payload containing list of objects.ImportExportStatus instances
Returns a list of the state of each named import/export or None if a status couldn't be retrieved

Variables Details [hide private]

_FILE_STORAGE_CALLS

Value:
[("file_storage_dir_create", SINGLE, None, constants.RPC_TMO_FAST, [("\
file_storage_dir", None, "File storage directory"),], None, None, "Cre\
ate the given file storage directory"), ("file_storage_dir_remove", SI\
NGLE, None, constants.RPC_TMO_FAST, [("file_storage_dir", None, "File \
storage directory"),], None, None, "Remove the given file storage dire\
ctory"), ("file_storage_dir_rename", SINGLE, None, constants.RPC_TMO_F\
AST, [("old_file_storage_dir", None, "Old name"), ("new_file_storage_d\
ir", None, "New name"),], None, None, "Rename file storage directory")\
...

_STORAGE_CALLS

Value:
[("storage_list", MULTI, None, constants.RPC_TMO_NORMAL, [("su_name", \
None, None), ("su_args", None, None), ("name", None, None), ("fields",\
 None, None),], None, None, "Get list of storage units"), ("storage_mo\
dify", SINGLE, None, constants.RPC_TMO_NORMAL, [("su_name", None, None\
), ("su_args", None, None), ("name", None, None), ("changes", None, No\
ne),], None, None, "Modify a storage unit"), ("storage_execute", SINGL\
E, None, constants.RPC_TMO_NORMAL, [("su_name", None, None), ("su_args\
", None, None), ("name", None, None), ("op", None, None),], None, None\
...

_INSTANCE_CALLS

Value:
[("instance_info", SINGLE, None, constants.RPC_TMO_URGENT, [("instance\
", None, "Instance name"), ("hname", None, "Hypervisor type"),], None,\
 None, "Returns information about a single instance"), ("all_instances\
_info", MULTI, None, constants.RPC_TMO_URGENT, [("hypervisor_list", No\
ne, "Hypervisors to query for instances"),], None, None, "Returns info\
rmation about all instances on the given nodes"), ("instance_list", MU\
LTI, None, constants.RPC_TMO_URGENT, [("hypervisor_list", None, "Hyper\
visors to query for instances"),], None, None, "Returns the list of ru\
...

_IMPEXP_CALLS

Value:
[("import_start", SINGLE, None, constants.RPC_TMO_NORMAL, [("opts", ED\
_OBJECT_DICT, None), ("instance", ED_INST_DICT, None), ("component", N\
one, None), ("dest", ED_IMPEXP_IO, "Import destination"),], None, None\
, "Starts an import daemon"), ("export_start", SINGLE, None, constants\
.RPC_TMO_NORMAL, [("opts", ED_OBJECT_DICT, None), ("host", None, None)\
, ("port", None, None), ("instance", ED_INST_DICT, None), ("component"\
, None, None), ("source", ED_IMPEXP_IO, "Export source"),], None, None\
, "Starts an export daemon"), ("impexp_status", SINGLE, None, constant\
...

_X509_CALLS

Value:
[("x509_cert_create", SINGLE, None, constants.RPC_TMO_NORMAL, [("valid\
ity", None, "Validity in seconds"),], None, None, "Creates a new X509 \
certificate for SSL/TLS"), ("x509_cert_remove", SINGLE, None, constant\
s.RPC_TMO_NORMAL, [("name", None, "Certificate name"),], None, None, "\
Removes a X509 certificate"),]

_BLOCKDEV_CALLS

Value:
[("bdev_sizes", MULTI, None, constants.RPC_TMO_URGENT, [("devices", No\
ne, None),], None, None, "Gets the sizes of requested block devices pr\
esent on a node"), ("blockdev_create", SINGLE, None, constants.RPC_TMO\
_NORMAL, [("bdev", ED_OBJECT_DICT, None), ("size", None, None), ("owne\
r", None, None), ("on_primary", None, None), ("info", None, None), ("e\
xclusive_storage", None, None),], None, None, "Request creation of a g\
iven block device"), ("blockdev_wipe", SINGLE, None, constants.RPC_TMO\
_SLOW, [("bdev", ED_SINGLE_DISK_DICT_DP, None), ("offset", None, None)\
...

_OS_CALLS

Value:
[("os_diagnose", MULTI, None, constants.RPC_TMO_FAST, [], None, None, \
"Request a diagnose of OS definitions"), ("os_validate", MULTI, None, \
constants.RPC_TMO_FAST, [("required", None, None), ("name", None, None\
), ("checks", None, None), ("params", None, None),], None, None, "Run \
a validation routine for a given OS"), ("os_get", SINGLE, None, consta\
nts.RPC_TMO_FAST, [("name", None, None),], None, _OsGetPostProc, "Retu\
rns an OS definition"),]

_EXTSTORAGE_CALLS

Value:
[("extstorage_diagnose", MULTI, None, constants.RPC_TMO_FAST, [], None\
, None, "Request a diagnose of ExtStorage Providers"),]

_NODE_CALLS

Value:
[("node_has_ip_address", SINGLE, None, constants.RPC_TMO_FAST, [("addr\
ess", None, "IP address"),], None, None, "Checks if a node has the giv\
en IP address"), ("node_info", MULTI, None, constants.RPC_TMO_URGENT, \
[("vg_names", None, "Names of the volume groups to ask for disk space \
information"), ("hv_names", None, "Names of the hypervisors to ask for\
 node information"), ("exclusive_storage", None, "Whether exclusive st\
orage is enabled"),], _NodeInfoPreProc, None, "Return node information\
"), ("node_verify", MULTI, None, constants.RPC_TMO_NORMAL, [("checkdic\
...

_MISC_CALLS

Value:
[("lv_list", MULTI, None, constants.RPC_TMO_URGENT, [("vg_name", None,\
 None),], None, None, "Gets the logical volumes present in a given vol\
ume group"), ("vg_list", MULTI, None, constants.RPC_TMO_URGENT, [], No\
ne, None, "Gets the volume group list"), ("bridges_exist", SINGLE, Non\
e, constants.RPC_TMO_URGENT, [("bridges_list", None, "Bridges which mu\
st be present on remote node"),], None, None, "Checks if a node has al\
l the bridges given"), ("etc_hosts_modify", SINGLE, None, constants.RP\
C_TMO_NORMAL, [("mode", None, "Mode to operate; currently L{constants.\
...

CALLS

Value:
{"RpcClientDefault": _Prepare(_IMPEXP_CALLS+ _X509_CALLS+ _OS_CALLS+ _\
NODE_CALLS+ _FILE_STORAGE_CALLS+ _MISC_CALLS+ _INSTANCE_CALLS+ _BLOCKD\
EV_CALLS+ _STORAGE_CALLS+ _EXTSTORAGE_CALLS), "RpcClientJobQueue": _Pr\
epare([("jobqueue_update", MULTI, None, constants.RPC_TMO_URGENT, [("f\
ile_name", None, None), ("content", ED_COMPRESS, None),], None, None, \
"Update job queue file"), ("jobqueue_purge", SINGLE, None, constants.R\
PC_TMO_NORMAL, [], None, None, "Purge job queue"), ("jobqueue_rename",\
 MULTI, None, constants.RPC_TMO_URGENT, [("rename", None, None),], Non\
...