ganeti.rpc.node.RpcRunner

class documentation

class RpcRunner(_RpcClientBase, _generated_rpc.RpcClientDefault, _generated_rpc.RpcClientBootstrap, _generated_rpc.RpcClientDnsOnly, _generated_rpc.RpcClientConfig):

View In Hierarchy

RPC runner class.

Method	`__init__`	Initialized the RPC runner.
Method	`_DeviceDict`	Undocumented
Method	`_DisksDictDP`	Wrapper for `AnnotateDiskParams`.
Method	`_EncodeImportExportIO`	Encodes import/export I/O information.
Method	`_EncodeNodeToDiskDictDP`	Encode dict of node name -> list of (disk, instance) tuples as values.
Method	`_InstDict`	Convert the given instance to a dict.
Method	`_InstDictHvpBepDp`	Wrapper for `_InstDict`.
Method	`_InstDictOspDp`	Wrapper for `_InstDict`.
Method	`_MultiDiskDictDP`	Wrapper for `AnnotateDiskParams`.
Method	`_NicDict`	Convert the given nic to a dict and encapsulate netinfo
Method	`_SingleDiskDictDP`	Wrapper for `AnnotateDiskParams`.
Instance Variable	`_cfg`	Undocumented

Inherited from _RpcClientBase:

Static Method	`_EncodeArg`	Encode argument.
Method	`_Call`	Entry point for automatically generated RPC wrappers.
Instance Variable	`_encoder`	Undocumented
Instance Variable	`_proc`	Undocumented

Inherited from RpcClientDefault (via _RpcClientBase):

Method	`call_accept_instance`	Wrapper for RPC call 'accept_instance'
Method	`call_all_instances_info`	Wrapper for RPC call 'all_instances_info'
Method	`call_bdev_sizes`	Wrapper for RPC call 'bdev_sizes'
Method	`call_blockdev_addchildren`	Wrapper for RPC call 'blockdev_addchildren'
Method	`call_blockdev_assemble`	Wrapper for RPC call 'blockdev_assemble'
Method	`call_blockdev_close`	Wrapper for RPC call 'blockdev_close'
Method	`call_blockdev_convert`	Wrapper for RPC call 'blockdev_convert'
Method	`call_blockdev_create`	Wrapper for RPC call 'blockdev_create'
Method	`call_blockdev_find`	Wrapper for RPC call 'blockdev_find'
Method	`call_blockdev_getdimensions`	Wrapper for RPC call 'blockdev_getdimensions'
Method	`call_blockdev_getmirrorstatus`	Wrapper for RPC call 'blockdev_getmirrorstatus'
Method	`call_blockdev_getmirrorstatus_multi`	Wrapper for RPC call 'blockdev_getmirrorstatus_multi'
Method	`call_blockdev_grow`	Wrapper for RPC call 'blockdev_grow'
Method	`call_blockdev_image`	Wrapper for RPC call 'blockdev_image'
Method	`call_blockdev_open`	Wrapper for RPC call 'blockdev_open'
Method	`call_blockdev_pause_resume_sync`	Wrapper for RPC call 'blockdev_pause_resume_sync'
Method	`call_blockdev_remove`	Wrapper for RPC call 'blockdev_remove'
Method	`call_blockdev_removechildren`	Wrapper for RPC call 'blockdev_removechildren'
Method	`call_blockdev_rename`	Wrapper for RPC call 'blockdev_rename'
Method	`call_blockdev_setinfo`	Wrapper for RPC call 'blockdev_setinfo'
Method	`call_blockdev_shutdown`	Wrapper for RPC call 'blockdev_shutdown'
Method	`call_blockdev_snapshot`	Wrapper for RPC call 'blockdev_snapshot'
Method	`call_blockdev_wipe`	Wrapper for RPC call 'blockdev_wipe'
Method	`call_bridges_exist`	Wrapper for RPC call 'bridges_exist'
Method	`call_drbd_attach_net`	Wrapper for RPC call 'drbd_attach_net'
Method	`call_drbd_disconnect_net`	Wrapper for RPC call 'drbd_disconnect_net'
Method	`call_drbd_helper`	Wrapper for RPC call 'drbd_helper'
Method	`call_drbd_needs_activation`	Wrapper for RPC call 'drbd_needs_activation'
Method	`call_drbd_wait_sync`	Wrapper for RPC call 'drbd_wait_sync'
Method	`call_etc_hosts_modify`	Wrapper for RPC call 'etc_hosts_modify'
Method	`call_export_info`	Wrapper for RPC call 'export_info'
Method	`call_export_list`	Wrapper for RPC call 'export_list'
Method	`call_export_remove`	Wrapper for RPC call 'export_remove'
Method	`call_export_start`	Wrapper for RPC call 'export_start'
Method	`call_extstorage_diagnose`	Wrapper for RPC call 'extstorage_diagnose'
Method	`call_file_storage_dir_create`	Wrapper for RPC call 'file_storage_dir_create'
Method	`call_file_storage_dir_remove`	Wrapper for RPC call 'file_storage_dir_remove'
Method	`call_file_storage_dir_rename`	Wrapper for RPC call 'file_storage_dir_rename'
Method	`call_finalize_export`	Wrapper for RPC call 'finalize_export'
Method	`call_get_file_info`	Wrapper for RPC call 'get_file_info'
Method	`call_get_watcher_pause`	Wrapper for RPC call 'get_watcher_pause'
Method	`call_hooks_runner`	Wrapper for RPC call 'hooks_runner'
Method	`call_hotplug_device`	Wrapper for RPC call 'hotplug_device'
Method	`call_hotplug_supported`	Wrapper for RPC call 'hotplug_supported'
Method	`call_hypervisor_validate_params`	Wrapper for RPC call 'hypervisor_validate_params'
Method	`call_iallocator_runner`	Wrapper for RPC call 'iallocator_runner'
Method	`call_impexp_abort`	Wrapper for RPC call 'impexp_abort'
Method	`call_impexp_cleanup`	Wrapper for RPC call 'impexp_cleanup'
Method	`call_impexp_status`	Wrapper for RPC call 'impexp_status'
Method	`call_import_start`	Wrapper for RPC call 'import_start'
Method	`call_instance_balloon_memory`	Wrapper for RPC call 'instance_balloon_memory'
Method	`call_instance_finalize_migration_dst`	Wrapper for RPC call 'instance_finalize_migration_dst'
Method	`call_instance_finalize_migration_src`	Wrapper for RPC call 'instance_finalize_migration_src'
Method	`call_instance_get_migration_status`	Wrapper for RPC call 'instance_get_migration_status'
Method	`call_instance_info`	Wrapper for RPC call 'instance_info'
Method	`call_instance_list`	Wrapper for RPC call 'instance_list'
Method	`call_instance_metadata_modify`	Wrapper for RPC call 'instance_metadata_modify'
Method	`call_instance_migratable`	Wrapper for RPC call 'instance_migratable'
Method	`call_instance_migrate`	Wrapper for RPC call 'instance_migrate'
Method	`call_instance_os_add`	Wrapper for RPC call 'instance_os_add'
Method	`call_instance_reboot`	Wrapper for RPC call 'instance_reboot'
Method	`call_instance_run_rename`	Wrapper for RPC call 'instance_run_rename'
Method	`call_instance_shutdown`	Wrapper for RPC call 'instance_shutdown'
Method	`call_instance_start`	Wrapper for RPC call 'instance_start'
Method	`call_lv_list`	Wrapper for RPC call 'lv_list'
Method	`call_migration_info`	Wrapper for RPC call 'migration_info'
Method	`call_node_configure_ovs`	Wrapper for RPC call 'node_configure_ovs'
Method	`call_node_crypto_tokens`	Wrapper for RPC call 'node_crypto_tokens'
Method	`call_node_demote_from_mc`	Wrapper for RPC call 'node_demote_from_mc'
Method	`call_node_ensure_daemon`	Wrapper for RPC call 'node_ensure_daemon'
Method	`call_node_has_ip_address`	Wrapper for RPC call 'node_has_ip_address'
Method	`call_node_info`	Wrapper for RPC call 'node_info'
Method	`call_node_powercycle`	Wrapper for RPC call 'node_powercycle'
Method	`call_node_ssh_key_add`	Wrapper for RPC call 'node_ssh_key_add'
Method	`call_node_ssh_key_remove`	Wrapper for RPC call 'node_ssh_key_remove'
Method	`call_node_ssh_keys_renew`	Wrapper for RPC call 'node_ssh_keys_renew'
Method	`call_node_verify`	Wrapper for RPC call 'node_verify'
Method	`call_node_volumes`	Wrapper for RPC call 'node_volumes'
Method	`call_os_diagnose`	Wrapper for RPC call 'os_diagnose'
Method	`call_os_export`	Wrapper for RPC call 'os_export'
Method	`call_os_validate`	Wrapper for RPC call 'os_validate'
Method	`call_restricted_command`	Wrapper for RPC call 'restricted_command'
Method	`call_run_oob`	Wrapper for RPC call 'run_oob'
Method	`call_set_watcher_pause`	Wrapper for RPC call 'set_watcher_pause'
Method	`call_storage_execute`	Wrapper for RPC call 'storage_execute'
Method	`call_storage_list`	Wrapper for RPC call 'storage_list'
Method	`call_storage_modify`	Wrapper for RPC call 'storage_modify'
Method	`call_test_delay`	Wrapper for RPC call 'test_delay'
Method	`call_vg_list`	Wrapper for RPC call 'vg_list'
Method	`call_x509_cert_create`	Wrapper for RPC call 'x509_cert_create'
Method	`call_x509_cert_remove`	Wrapper for RPC call 'x509_cert_remove'
Constant	`_CALLS`	Undocumented

Inherited from RpcClientBootstrap (via _RpcClientBase, RpcClientDefault):

Method	`call_master_node_name`	Wrapper for RPC call 'master_node_name'
Method	`call_node_activate_master_ip`	Wrapper for RPC call 'node_activate_master_ip'
Method	`call_node_change_master_netmask`	Wrapper for RPC call 'node_change_master_netmask'
Method	`call_node_deactivate_master_ip`	Wrapper for RPC call 'node_deactivate_master_ip'
Method	`call_node_leave_cluster`	Wrapper for RPC call 'node_leave_cluster'
Method	`call_node_start_master_daemons`	Wrapper for RPC call 'node_start_master_daemons'
Method	`call_node_stop_master`	Wrapper for RPC call 'node_stop_master'

Inherited from RpcClientDnsOnly (via _RpcClientBase, RpcClientDefault, RpcClientBootstrap):

Method	`call_node_verify_light`	Wrapper for RPC call 'node_verify_light'
Method	`call_version`	Wrapper for RPC call 'version'

Inherited from RpcClientConfig (via _RpcClientBase, RpcClientDefault, RpcClientBootstrap, RpcClientDnsOnly):

Method	`call_upload_file`	Wrapper for RPC call 'upload_file'
Method	`call_upload_file_single`	Wrapper for RPC call 'upload_file_single'
Method	`call_write_ssconf_files`	Wrapper for RPC call 'write_ssconf_files'

def __init__(self, cfg, lock_monitor_cb, _req_process_fn=None, _getents=None): ¶

overrides ganeti.rpc.node._RpcClientBase.__init__

Initialized the RPC runner.

Parameters
cfg:`config.ConfigWriter`	Configuration
lock_monitor_cb:callable	Lock monitor callback
_req_process_fn	Undocumented
_getents	Undocumented

def _DeviceDict(self, _, devinstance): ¶

Undocumented

def _DisksDictDP(self, node, instance_disks): ¶

Wrapper for AnnotateDiskParams.

def _EncodeImportExportIO(self, node, ieinfo): ¶

Encodes import/export I/O information.

def _EncodeNodeToDiskDictDP(self, node, value): ¶

Encode dict of node name -> list of (disk, instance) tuples as values.

def _InstDict(self, node, instance, hvp=None, bep=None, osp=None): ¶

Convert the given instance to a dict.

This is done via the instance's ToDict() method and additionally we fill the hvparams with the cluster defaults.

Parameters
node	Undocumented
instance:`objects.Instance`	an Instance object
hvp:dict or None	a dictionary with overridden hypervisor parameters
bep:dict or None	a dictionary with overridden backend parameters
osp:dict or None	a dictionary with overridden os parameters
Returns
dict	the instance dict, with the hvparams filled with the cluster defaults

def _InstDictHvpBepDp(self, node, instance_params): ¶

Wrapper for _InstDict.

def _InstDictOspDp(self, node, instance_osparams): ¶

Wrapper for _InstDict.

def _MultiDiskDictDP(self, node, disks_insts): ¶

Wrapper for AnnotateDiskParams.

Supports a list of (disk, instance) tuples.

def _NicDict(self, _, nic): ¶

Convert the given nic to a dict and encapsulate netinfo

def _SingleDiskDictDP(self, node, instance_disk): ¶

Wrapper for AnnotateDiskParams.

_cfg = ¶

Undocumented