Package ganeti :: Package rpc :: Module node :: Class RpcRunner
[hide private]
[frames] | no frames]

Class RpcRunner

source code


RPC runner class.

Instance Methods [hide private]
 
__init__(self, cfg, lock_monitor_cb, _req_process_fn=None, _getents=None)
Initialized the RPC runner.
source code
 
_NicDict(self, _, nic)
Convert the given nic to a dict and encapsulate netinfo
source code
 
_DeviceDict(self, _, (device, instance)) source code
dict
_InstDict(self, node, instance, hvp=None, bep=None, osp=None)
Convert the given instance to a dict.
source code
 
_InstDictHvpBepDp(self, node, (instance, hvp, bep))
Wrapper for _InstDict.
source code
 
_InstDictOspDp(self, node, (instance, osparams))
Wrapper for _InstDict.
source code
 
_DisksDictDP(self, node, (disks, instance))
Wrapper for AnnotateDiskParams.
source code
 
_MultiDiskDictDP(self, node, disks_insts)
Wrapper for AnnotateDiskParams.
source code
 
_SingleDiskDictDP(self, node, (disk, instance))
Wrapper for AnnotateDiskParams.
source code
 
_EncodeNodeToDiskDictDP(self, node, value)
Encode dict of node name -> list of (disk, instance) tuples as values.
source code
 
_EncodeImportExportIO(self, node, (ieio, ieioargs))
Encodes import/export I/O information.
source code

Inherited from _RpcClientBase (private): _Call

Inherited from _generated_rpc.RpcClientDefault: call_accept_instance, call_all_instances_info, call_bdev_sizes, call_blockdev_addchildren, call_blockdev_assemble, call_blockdev_close, call_blockdev_convert, call_blockdev_create, call_blockdev_find, call_blockdev_getdimensions, call_blockdev_getmirrorstatus, call_blockdev_getmirrorstatus_multi, call_blockdev_grow, call_blockdev_image, call_blockdev_open, call_blockdev_pause_resume_sync, call_blockdev_remove, call_blockdev_removechildren, call_blockdev_rename, call_blockdev_setinfo, call_blockdev_shutdown, call_blockdev_snapshot, call_blockdev_wipe, call_bridges_exist, call_drbd_attach_net, call_drbd_disconnect_net, call_drbd_helper, call_drbd_needs_activation, call_drbd_wait_sync, call_etc_hosts_modify, call_export_info, call_export_list, call_export_remove, call_export_start, call_extstorage_diagnose, call_file_storage_dir_create, call_file_storage_dir_remove, call_file_storage_dir_rename, call_finalize_export, call_get_file_info, call_get_watcher_pause, call_hooks_runner, call_hotplug_device, call_hotplug_supported, call_hypervisor_validate_params, call_iallocator_runner, call_impexp_abort, call_impexp_cleanup, call_impexp_status, call_import_start, call_instance_balloon_memory, call_instance_finalize_migration_dst, call_instance_finalize_migration_src, call_instance_get_migration_status, call_instance_info, call_instance_list, call_instance_metadata_modify, call_instance_migratable, call_instance_migrate, call_instance_os_add, call_instance_reboot, call_instance_run_rename, call_instance_shutdown, call_instance_start, call_lv_list, call_migration_info, call_node_configure_ovs, call_node_crypto_tokens, call_node_demote_from_mc, call_node_ensure_daemon, call_node_has_ip_address, call_node_info, call_node_powercycle, call_node_ssh_key_add, call_node_ssh_key_remove, call_node_ssh_keys_renew, call_node_verify, call_node_volumes, call_os_diagnose, call_os_export, call_os_validate, call_restricted_command, call_run_oob, call_set_watcher_pause, call_storage_execute, call_storage_list, call_storage_modify, call_test_delay, call_vg_list, call_x509_cert_create, call_x509_cert_remove

Inherited from _generated_rpc.RpcClientBootstrap: call_master_node_name, call_node_activate_master_ip, call_node_change_master_netmask, call_node_deactivate_master_ip, call_node_leave_cluster, call_node_start_master_daemons, call_node_stop_master

Inherited from _generated_rpc.RpcClientDnsOnly: call_node_verify_light, call_version

Inherited from _generated_rpc.RpcClientConfig: call_upload_file, call_upload_file_single, call_write_ssconf_files

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Static Methods [hide private]

Inherited from _RpcClientBase (private): _EncodeArg

Class Variables [hide private]

Inherited from _generated_rpc.RpcClientDefault (private): _CALLS

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, cfg, lock_monitor_cb, _req_process_fn=None, _getents=None)
(Constructor)

source code 

Initialized the RPC runner.

Parameters:
Overrides: object.__init__

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

source code 

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:
  • 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

_MultiDiskDictDP(self, node, disks_insts)

source code 

Wrapper for AnnotateDiskParams.

Supports a list of (disk, instance) tuples.