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

Source Code for Module ganeti._generated_rpc

   1  # This code is automatically generated at build time. 
   2  # Do not modify manually. 
   3   
   4  """Automatically generated RPC client wrappers. 
   5   
   6  """ 
   7   
   8  from ganeti import rpc_defs 
   9   
  10  # Definitions from 'lib/rpc_defs.py' 
  11   
12 -class RpcClientBootstrap(object):
13 # E1101: Non-existent members 14 # R0904: Too many public methods 15 # pylint: disable=E1101,R0904 16 _CALLS = rpc_defs.CALLS['RpcClientBootstrap'] 17
18 - def call_master_node_name(self, node_list, 19 _def=_CALLS['master_node_name']):
20 """Wrapper for RPC call 'master_node_name' 21 22 Returns the master node name 23 24 @note: This is a multi-node call with a timeout of 1m 0s 25 @type node_list: list of string 26 @param node_list: List of node names 27 28 """ 29 return (self._Call(_def, node_list, []))
30
31 - def call_node_activate_master_ip(self, node, master_params, 32 use_external_mip_script, _def=_CALLS['node_activate_master_ip']):
33 """Wrapper for RPC call 'node_activate_master_ip' 34 35 Activates master IP on a node 36 37 @note: This is a single-node call with a timeout of 5m 0s 38 @type node: string 39 @param node: Node name 40 @param master_params: Network parameters of the master 41 @param use_external_mip_script: Whether to use the user-provided 42 master IP address setup script 43 44 """ 45 return (self._Call(_def, [node], [master_params, 46 use_external_mip_script])[node])
47
48 - def call_node_change_master_netmask(self, node, old_netmask, netmask, 49 master_ip, master_netdev, 50 _def=_CALLS['node_change_master_netmask']):
51 """Wrapper for RPC call 'node_change_master_netmask' 52 53 Change master IP netmask 54 55 @note: This is a single-node call with a timeout of 5m 0s 56 @type node: string 57 @param node: Node name 58 @param old_netmask: The old value of the netmask 59 @param netmask: The new value of the netmask 60 @param master_ip: The master IP 61 @param master_netdev: The master network device 62 63 """ 64 return (self._Call(_def, [node], [old_netmask, netmask, master_ip, 65 master_netdev])[node])
66
67 - def call_node_deactivate_master_ip(self, node, master_params, 68 use_external_mip_script, _def=_CALLS['node_deactivate_master_ip']):
69 """Wrapper for RPC call 'node_deactivate_master_ip' 70 71 Deactivates master IP on a node 72 73 @note: This is a single-node call with a timeout of 5m 0s 74 @type node: string 75 @param node: Node name 76 @param master_params: Network parameters of the master 77 @param use_external_mip_script: Whether to use the user-provided 78 master IP address setup script 79 80 """ 81 return (self._Call(_def, [node], [master_params, 82 use_external_mip_script])[node])
83
84 - def call_node_leave_cluster(self, node, modify_ssh_setup, 85 _def=_CALLS['node_leave_cluster']):
86 """Wrapper for RPC call 'node_leave_cluster' 87 88 Requests a node to clean the cluster information it has 89 90 @note: This is a single-node call with a timeout of 15m 0s 91 @type node: string 92 @param node: Node name 93 94 """ 95 return (self._Call(_def, [node], [modify_ssh_setup])[node])
96
97 - def call_node_start_master_daemons(self, node, no_voting, 98 _def=_CALLS['node_start_master_daemons']):
99 """Wrapper for RPC call 'node_start_master_daemons' 100 101 Starts master daemons on a node 102 103 @note: This is a single-node call with a timeout of 5m 0s 104 @type node: string 105 @param node: Node name 106 107 """ 108 return (self._Call(_def, [node], [no_voting])[node])
109
110 - def call_node_stop_master(self, node, 111 _def=_CALLS['node_stop_master']):
112 """Wrapper for RPC call 'node_stop_master' 113 114 Deactivates master IP and stops master daemons on a node 115 116 @note: This is a single-node call with a timeout of 5m 0s 117 @type node: string 118 @param node: Node name 119 120 """ 121 return (self._Call(_def, [node], [])[node])
122 123
124 -class RpcClientConfig(object):
125 # E1101: Non-existent members 126 # R0904: Too many public methods 127 # pylint: disable=E1101,R0904 128 _CALLS = rpc_defs.CALLS['RpcClientConfig'] 129
130 - def call_upload_file(self, node_list, file_name, 131 _def=_CALLS['upload_file']):
132 """Wrapper for RPC call 'upload_file' 133 134 Upload files 135 136 @note: This is a multi-node call with a timeout of 15m 0s 137 @type node_list: list of string 138 @param node_list: List of node names 139 140 """ 141 return (self._Call(_def, node_list, [file_name]))
142
143 - def call_upload_file_single(self, node_list, file_name, content, mode, 144 uid, gid, atime, mtime, _def=_CALLS['upload_file_single']):
145 """Wrapper for RPC call 'upload_file_single' 146 147 Upload files 148 149 @note: This is a multi-node call with a timeout of 15m 0s 150 @type node_list: list of string 151 @param node_list: List of node names 152 @param file_name: The name of the file 153 @param content: The data to be uploaded 154 @param mode: The mode of the file or None 155 @param uid: The owner of the file 156 @param gid: The group of the file 157 @param atime: The file's last access time 158 @param mtime: The file's last modification time 159 160 """ 161 return (self._Call(_def, node_list, [file_name, content, mode, uid, 162 gid, atime, mtime]))
163
164 - def call_write_ssconf_files(self, node_list, values, 165 _def=_CALLS['write_ssconf_files']):
166 """Wrapper for RPC call 'write_ssconf_files' 167 168 Write ssconf files 169 170 @note: This is a multi-node call with a timeout of 15m 0s 171 @type node_list: list of string 172 @param node_list: List of node names 173 174 """ 175 return (self._Call(_def, node_list, [values]))
176 177
178 -class RpcClientDefault(object):
179 # E1101: Non-existent members 180 # R0904: Too many public methods 181 # pylint: disable=E1101,R0904 182 _CALLS = rpc_defs.CALLS['RpcClientDefault'] 183
184 - def call_accept_instance(self, node, instance, info, target, 185 _def=_CALLS['accept_instance']):
186 """Wrapper for RPC call 'accept_instance' 187 188 Prepare a node to accept an instance 189 190 @note: This is a single-node call with a timeout of 15m 0s 191 @type node: string 192 @param node: Node name 193 @param instance: Instance object 194 @param info: Result for the call_migration_info call 195 @param target: Target hostname (usually an IP address) 196 197 """ 198 return (self._Call(_def, [node], [instance, info, target])[node])
199
200 - def call_all_instances_info(self, node_list, hypervisor_list, 201 all_hvparams, _def=_CALLS['all_instances_info']):
202 """Wrapper for RPC call 'all_instances_info' 203 204 Returns information about all instances on the given nodes 205 206 @note: This is a multi-node call with a timeout of 1m 0s 207 @type node_list: list of string 208 @param node_list: List of node names 209 @param hypervisor_list: Hypervisors to query for instances 210 @param all_hvparams: Dictionary mapping hypervisor names to hvparams 211 212 """ 213 return (self._Call(_def, node_list, [hypervisor_list, all_hvparams]))
214
215 - def call_bdev_sizes(self, node_list, devices, 216 _def=_CALLS['bdev_sizes']):
217 """Wrapper for RPC call 'bdev_sizes' 218 219 Gets the sizes of requested block devices present on a node 220 221 @note: This is a multi-node call with a timeout of 1m 0s 222 @type node_list: list of string 223 @param node_list: List of node names 224 225 """ 226 return (self._Call(_def, node_list, [devices]))
227
228 - def call_blockdev_addchildren(self, node, bdev, ndevs, 229 _def=_CALLS['blockdev_addchildren']):
230 """Wrapper for RPC call 'blockdev_addchildren' 231 232 Request adding a list of children to a (mirroring) device 233 234 @note: This is a single-node call with a timeout of 15m 0s 235 @type node: string 236 @param node: Node name 237 238 """ 239 return (self._Call(_def, [node], [bdev, ndevs])[node])
240
241 - def call_blockdev_assemble(self, node, disk, instance, on_primary, 242 idx, _def=_CALLS['blockdev_assemble']):
243 """Wrapper for RPC call 'blockdev_assemble' 244 245 Request assembling of a given block device 246 247 @note: This is a single-node call with a timeout of 15m 0s 248 @type node: string 249 @param node: Node name 250 251 """ 252 return (self._Call(_def, [node], [disk, instance, on_primary, 253 idx])[node])
254
255 - def call_blockdev_close(self, node, instance_name, disks, 256 _def=_CALLS['blockdev_close']):
257 """Wrapper for RPC call 'blockdev_close' 258 259 Closes the given block devices 260 261 @note: This is a single-node call with a timeout of 15m 0s 262 @type node: string 263 @param node: Node name 264 265 """ 266 return (self._Call(_def, [node], [instance_name, disks])[node])
267
268 - def call_blockdev_convert(self, node, bdev_src, bdev_dest, 269 _def=_CALLS['blockdev_convert']):
270 """Wrapper for RPC call 'blockdev_convert' 271 272 Request the copy of the source block device to the destination one 273 274 @note: This is a single-node call with a timeout of 1h 0m 0s 275 @type node: string 276 @param node: Node name 277 278 """ 279 return (self._Call(_def, [node], [bdev_src, bdev_dest])[node])
280
281 - def call_blockdev_create(self, node, bdev, size, owner, on_primary, 282 info, exclusive_storage, _def=_CALLS['blockdev_create']):
283 """Wrapper for RPC call 'blockdev_create' 284 285 Request creation of a given block device 286 287 @note: This is a single-node call with a timeout of 15m 0s 288 @type node: string 289 @param node: Node name 290 291 """ 292 return (self._Call(_def, [node], [bdev, size, owner, on_primary, info, 293 exclusive_storage])[node])
294
295 - def call_blockdev_find(self, node, disk, 296 _def=_CALLS['blockdev_find']):
297 """Wrapper for RPC call 'blockdev_find' 298 299 Request identification of a given block device 300 301 @note: This is a single-node call with a timeout of 15m 0s 302 @type node: string 303 @param node: Node name 304 305 """ 306 return (self._Call(_def, [node], [disk])[node])
307
308 - def call_blockdev_getdimensions(self, node, disks, 309 _def=_CALLS['blockdev_getdimensions']):
310 """Wrapper for RPC call 'blockdev_getdimensions' 311 312 Returns size and spindles of the given disks 313 314 @note: This is a single-node call with a timeout of 15m 0s 315 @type node: string 316 @param node: Node name 317 318 """ 319 return (self._Call(_def, [node], [disks])[node])
320
321 - def call_blockdev_getmirrorstatus(self, node, disks, 322 _def=_CALLS['blockdev_getmirrorstatus']):
323 """Wrapper for RPC call 'blockdev_getmirrorstatus' 324 325 Request status of a (mirroring) device 326 327 @note: This is a single-node call with a timeout of 15m 0s 328 @type node: string 329 @param node: Node name 330 331 """ 332 return (self._Call(_def, [node], [disks])[node])
333
334 - def call_blockdev_getmirrorstatus_multi(self, node_list, node_disks, 335 _def=_CALLS['blockdev_getmirrorstatus_multi']):
336 """Wrapper for RPC call 'blockdev_getmirrorstatus_multi' 337 338 Request status of (mirroring) devices from multiple nodes 339 340 @note: This is a multi-node call with a timeout of 15m 0s 341 @type node_list: list of string 342 @param node_list: List of node names 343 344 """ 345 return (self._Call(_def, node_list, [node_disks]))
346
347 - def call_blockdev_grow(self, node, cf_bdev, amount, dryrun, 348 backingstore, es_flag, _def=_CALLS['blockdev_grow']):
349 """Wrapper for RPC call 'blockdev_grow' 350 351 Request growing of the given block device by a given amount 352 353 @note: This is a single-node call with a timeout of 15m 0s 354 @type node: string 355 @param node: Node name 356 357 """ 358 return (self._Call(_def, [node], [cf_bdev, amount, dryrun, 359 backingstore, es_flag])[node])
360
361 - def call_blockdev_image(self, node, bdev, image, size, 362 _def=_CALLS['blockdev_image']):
363 """Wrapper for RPC call 'blockdev_image' 364 365 Request to dump an image with given size onto a block device 366 367 @note: This is a single-node call with a timeout of 1h 0m 0s 368 @type node: string 369 @param node: Node name 370 371 """ 372 return (self._Call(_def, [node], [bdev, image, size])[node])
373
374 - def call_blockdev_open(self, node, instance_name, disks, exclusive, 375 _def=_CALLS['blockdev_open']):
376 """Wrapper for RPC call 'blockdev_open' 377 378 Opens the given block devices in required mode 379 380 @note: This is a single-node call with a timeout of 15m 0s 381 @type node: string 382 @param node: Node name 383 384 """ 385 return (self._Call(_def, [node], [instance_name, disks, 386 exclusive])[node])
387
388 - def call_blockdev_pause_resume_sync(self, node, disks, pause, 389 _def=_CALLS['blockdev_pause_resume_sync']):
390 """Wrapper for RPC call 'blockdev_pause_resume_sync' 391 392 Request a pause/resume of given block device 393 394 @note: This is a single-node call with a timeout of 15m 0s 395 @type node: string 396 @param node: Node name 397 398 """ 399 return (self._Call(_def, [node], [disks, pause])[node])
400
401 - def call_blockdev_remove(self, node, bdev, 402 _def=_CALLS['blockdev_remove']):
403 """Wrapper for RPC call 'blockdev_remove' 404 405 Request removal of a given block device 406 407 @note: This is a single-node call with a timeout of 15m 0s 408 @type node: string 409 @param node: Node name 410 411 """ 412 return (self._Call(_def, [node], [bdev])[node])
413
414 - def call_blockdev_removechildren(self, node, bdev, ndevs, 415 _def=_CALLS['blockdev_removechildren']):
416 """Wrapper for RPC call 'blockdev_removechildren' 417 418 Request removing a list of children from a (mirroring) device 419 420 @note: This is a single-node call with a timeout of 15m 0s 421 @type node: string 422 @param node: Node name 423 424 """ 425 return (self._Call(_def, [node], [bdev, ndevs])[node])
426
427 - def call_blockdev_rename(self, node, devlist, 428 _def=_CALLS['blockdev_rename']):
429 """Wrapper for RPC call 'blockdev_rename' 430 431 Request rename of the given block devices 432 433 @note: This is a single-node call with a timeout of 15m 0s 434 @type node: string 435 @param node: Node name 436 437 """ 438 return (self._Call(_def, [node], [devlist])[node])
439
440 - def call_blockdev_setinfo(self, node, disk, info, 441 _def=_CALLS['blockdev_setinfo']):
442 """Wrapper for RPC call 'blockdev_setinfo' 443 444 Sets metadata information on a given block device 445 446 @note: This is a single-node call with a timeout of 15m 0s 447 @type node: string 448 @param node: Node name 449 450 """ 451 return (self._Call(_def, [node], [disk, info])[node])
452
453 - def call_blockdev_shutdown(self, node, disk, 454 _def=_CALLS['blockdev_shutdown']):
455 """Wrapper for RPC call 'blockdev_shutdown' 456 457 Request shutdown of a given block device 458 459 @note: This is a single-node call with a timeout of 15m 0s 460 @type node: string 461 @param node: Node name 462 463 """ 464 return (self._Call(_def, [node], [disk])[node])
465
466 - def call_blockdev_snapshot(self, node, cf_bdev, snap_name, snap_size, 467 _def=_CALLS['blockdev_snapshot']):
468 """Wrapper for RPC call 'blockdev_snapshot' 469 470 Export a given disk to another node 471 472 @note: This is a single-node call with a timeout of 15m 0s 473 @type node: string 474 @param node: Node name 475 476 """ 477 return (self._Call(_def, [node], [cf_bdev, snap_name, 478 snap_size])[node])
479
480 - def call_blockdev_wipe(self, node, bdev, offset, size, 481 _def=_CALLS['blockdev_wipe']):
482 """Wrapper for RPC call 'blockdev_wipe' 483 484 Request wipe at given offset with given size of a block device 485 486 @note: This is a single-node call with a timeout of 1h 0m 0s 487 @type node: string 488 @param node: Node name 489 490 """ 491 return (self._Call(_def, [node], [bdev, offset, size])[node])
492
493 - def call_bridges_exist(self, node, bridges_list, 494 _def=_CALLS['bridges_exist']):
495 """Wrapper for RPC call 'bridges_exist' 496 497 Checks if a node has all the bridges given 498 499 @note: This is a single-node call with a timeout of 1m 0s 500 @type node: string 501 @param node: Node name 502 @param bridges_list: Bridges which must be present on remote node 503 504 """ 505 return (self._Call(_def, [node], [bridges_list])[node])
506
507 - def call_drbd_attach_net(self, node_list, disks, multimaster, 508 _def=_CALLS['drbd_attach_net']):
509 """Wrapper for RPC call 'drbd_attach_net' 510 511 Connects the given DRBD devices 512 513 @note: This is a multi-node call with a timeout of 15m 0s 514 @type node_list: list of string 515 @param node_list: List of node names 516 517 """ 518 return (self._Call(_def, node_list, [disks, multimaster]))
519
520 - def call_drbd_disconnect_net(self, node_list, disks, 521 _def=_CALLS['drbd_disconnect_net']):
522 """Wrapper for RPC call 'drbd_disconnect_net' 523 524 Disconnects the network of the given drbd devices 525 526 @note: This is a multi-node call with a timeout of 15m 0s 527 @type node_list: list of string 528 @param node_list: List of node names 529 530 """ 531 return (self._Call(_def, node_list, [disks]))
532
533 - def call_drbd_helper(self, node_list, _def=_CALLS['drbd_helper']):
534 """Wrapper for RPC call 'drbd_helper' 535 536 Gets DRBD helper 537 538 @note: This is a multi-node call with a timeout of 1m 0s 539 @type node_list: list of string 540 @param node_list: List of node names 541 542 """ 543 return (self._Call(_def, node_list, []))
544
545 - def call_drbd_needs_activation(self, node, disks, 546 _def=_CALLS['drbd_needs_activation']):
547 """Wrapper for RPC call 'drbd_needs_activation' 548 549 Returns the drbd disks which need activation 550 551 @note: This is a single-node call with a timeout of 15m 0s 552 @type node: string 553 @param node: Node name 554 555 """ 556 return (self._Call(_def, [node], [disks])[node])
557
558 - def call_drbd_wait_sync(self, node_list, disks, 559 _def=_CALLS['drbd_wait_sync']):
560 """Wrapper for RPC call 'drbd_wait_sync' 561 562 Waits for the synchronization of drbd devices is complete 563 564 @note: This is a multi-node call with a timeout of 1h 0m 0s 565 @type node_list: list of string 566 @param node_list: List of node names 567 568 """ 569 return (self._Call(_def, node_list, [disks]))
570
571 - def call_etc_hosts_modify(self, node, mode, name, ip, 572 _def=_CALLS['etc_hosts_modify']):
573 """Wrapper for RPC call 'etc_hosts_modify' 574 575 Modify hosts file with name 576 577 @note: This is a single-node call with a timeout of 15m 0s 578 @type node: string 579 @param node: Node name 580 @param mode: Mode to operate; currently L{constants.ETC_HOSTS_ADD} or 581 L{constants.ETC_HOSTS_REMOVE} 582 @param name: Hostname to be modified 583 @param ip: IP address (L{constants.ETC_HOSTS_ADD} only) 584 585 """ 586 return (self._Call(_def, [node], [mode, name, ip])[node])
587
588 - def call_export_info(self, node, path, _def=_CALLS['export_info']):
589 """Wrapper for RPC call 'export_info' 590 591 Queries the export information in a given path 592 593 @note: This is a single-node call with a timeout of 5m 0s 594 @type node: string 595 @param node: Node name 596 597 """ 598 return (self._Call(_def, [node], [path])[node])
599
600 - def call_export_list(self, node_list, _def=_CALLS['export_list']):
601 """Wrapper for RPC call 'export_list' 602 603 Gets the stored exports list 604 605 @note: This is a multi-node call with a timeout of 5m 0s 606 @type node_list: list of string 607 @param node_list: List of node names 608 609 """ 610 return (self._Call(_def, node_list, []))
611
612 - def call_export_remove(self, node, export, 613 _def=_CALLS['export_remove']):
614 """Wrapper for RPC call 'export_remove' 615 616 Requests removal of a given export 617 618 @note: This is a single-node call with a timeout of 5m 0s 619 @type node: string 620 @param node: Node name 621 622 """ 623 return (self._Call(_def, [node], [export])[node])
624
625 - def call_export_start(self, node, opts, host, port, instance, 626 component, source, _def=_CALLS['export_start']):
627 """Wrapper for RPC call 'export_start' 628 629 Starts an export daemon 630 631 @note: This is a single-node call with a timeout of 15m 0s 632 @type node: string 633 @param node: Node name 634 @param source: Export source 635 636 """ 637 return (self._Call(_def, [node], [opts, host, port, instance, 638 component, source])[node])
639
640 - def call_extstorage_diagnose(self, node_list, 641 _def=_CALLS['extstorage_diagnose']):
642 """Wrapper for RPC call 'extstorage_diagnose' 643 644 Request a diagnose of ExtStorage Providers 645 646 @note: This is a multi-node call with a timeout of 5m 0s 647 @type node_list: list of string 648 @param node_list: List of node names 649 650 """ 651 return (self._Call(_def, node_list, []))
652
653 - def call_file_storage_dir_create(self, node, file_storage_dir, 654 _def=_CALLS['file_storage_dir_create']):
655 """Wrapper for RPC call 'file_storage_dir_create' 656 657 Create the given file storage directory 658 659 @note: This is a single-node call with a timeout of 5m 0s 660 @type node: string 661 @param node: Node name 662 @param file_storage_dir: File storage directory 663 664 """ 665 return (self._Call(_def, [node], [file_storage_dir])[node])
666
667 - def call_file_storage_dir_remove(self, node, file_storage_dir, 668 _def=_CALLS['file_storage_dir_remove']):
669 """Wrapper for RPC call 'file_storage_dir_remove' 670 671 Remove the given file storage directory 672 673 @note: This is a single-node call with a timeout of 5m 0s 674 @type node: string 675 @param node: Node name 676 @param file_storage_dir: File storage directory 677 678 """ 679 return (self._Call(_def, [node], [file_storage_dir])[node])
680
681 - def call_file_storage_dir_rename(self, node, old_file_storage_dir, 682 new_file_storage_dir, _def=_CALLS['file_storage_dir_rename']):
683 """Wrapper for RPC call 'file_storage_dir_rename' 684 685 Rename file storage directory 686 687 @note: This is a single-node call with a timeout of 5m 0s 688 @type node: string 689 @param node: Node name 690 @param old_file_storage_dir: Old name 691 @param new_file_storage_dir: New name 692 693 """ 694 return (self._Call(_def, [node], [old_file_storage_dir, 695 new_file_storage_dir])[node])
696
697 - def call_finalize_export(self, node, instance, snap_disks, 698 _def=_CALLS['finalize_export']):
699 """Wrapper for RPC call 'finalize_export' 700 701 Request the completion of an export operation 702 703 @note: This is a single-node call with a timeout of 15m 0s 704 @type node: string 705 @param node: Node name 706 707 """ 708 return (self._Call(_def, [node], [instance, snap_disks])[node])
709
710 - def call_get_file_info(self, node, file_path, 711 _def=_CALLS['get_file_info']):
712 """Wrapper for RPC call 'get_file_info' 713 714 Checks if a file exists and reports on it 715 716 @note: This is a single-node call with a timeout of 5m 0s 717 @type node: string 718 @param node: Node name 719 720 """ 721 return (self._Call(_def, [node], [file_path])[node])
722
723 - def call_get_watcher_pause(self, node, 724 _def=_CALLS['get_watcher_pause']):
725 """Wrapper for RPC call 'get_watcher_pause' 726 727 Get watcher pause end 728 729 @note: This is a single-node call with a timeout of 1m 0s 730 @type node: string 731 @param node: Node name 732 733 """ 734 return (self._Call(_def, [node], [])[node])
735
736 - def call_hooks_runner(self, node_list, hpath, phase, env, 737 _def=_CALLS['hooks_runner']):
738 """Wrapper for RPC call 'hooks_runner' 739 740 Call the hooks runner 741 742 @note: This is a multi-node call with a timeout of 15m 0s 743 @type node_list: list of string 744 @param node_list: List of node names 745 746 """ 747 return (self._Call(_def, node_list, [hpath, phase, env]))
748
749 - def call_hotplug_device(self, node, instance, action, dev_type, 750 device, extra, seq, _def=_CALLS['hotplug_device']):
751 """Wrapper for RPC call 'hotplug_device' 752 753 Hoplug a device to a running instance 754 755 @note: This is a single-node call with a timeout of 15m 0s 756 @type node: string 757 @param node: Node name 758 @param instance: Instance object 759 @param action: Hotplug Action 760 @param dev_type: Device type 761 @param device: Device dict 762 @param extra: Extra info for device (dev_path for disk) 763 @param seq: Device seq 764 765 """ 766 return (self._Call(_def, [node], [instance, action, dev_type, device, 767 extra, seq])[node])
768
769 - def call_hotplug_supported(self, node, instance, 770 _def=_CALLS['hotplug_supported']):
771 """Wrapper for RPC call 'hotplug_supported' 772 773 Check if hotplug is supported 774 775 @note: This is a single-node call with a timeout of 15m 0s 776 @type node: string 777 @param node: Node name 778 @param instance: Instance object 779 780 """ 781 return (self._Call(_def, [node], [instance])[node])
782
783 - def call_hypervisor_validate_params(self, node_list, hvname, hvfull, 784 _def=_CALLS['hypervisor_validate_params']):
785 """Wrapper for RPC call 'hypervisor_validate_params' 786 787 Validate hypervisor params 788 789 @note: This is a multi-node call with a timeout of 15m 0s 790 @type node_list: list of string 791 @param node_list: List of node names 792 @param hvname: Hypervisor name 793 @param hvfull: Parameters to be validated 794 795 """ 796 return (self._Call(_def, node_list, [hvname, hvfull]))
797
798 - def call_iallocator_runner(self, node, name, idata, 799 default_iallocator_params, _def=_CALLS['iallocator_runner']):
800 """Wrapper for RPC call 'iallocator_runner' 801 802 Call an iallocator on a remote node 803 804 @note: This is a single-node call with a timeout of 15m 0s 805 @type node: string 806 @param node: Node name 807 @param name: Iallocator name 808 @param idata: JSON-encoded input string 809 @param default_iallocator_params: Additional iallocator parameters 810 811 """ 812 return (self._Call(_def, [node], [name, idata, 813 default_iallocator_params])[node])
814
815 - def call_impexp_abort(self, node, name, _def=_CALLS['impexp_abort']):
816 """Wrapper for RPC call 'impexp_abort' 817 818 Aborts an import or export 819 820 @note: This is a single-node call with a timeout of 15m 0s 821 @type node: string 822 @param node: Node name 823 @param name: Import/export name 824 825 """ 826 return (self._Call(_def, [node], [name])[node])
827
828 - def call_impexp_cleanup(self, node, name, 829 _def=_CALLS['impexp_cleanup']):
830 """Wrapper for RPC call 'impexp_cleanup' 831 832 Cleans up after an import or export 833 834 @note: This is a single-node call with a timeout of 15m 0s 835 @type node: string 836 @param node: Node name 837 @param name: Import/export name 838 839 """ 840 return (self._Call(_def, [node], [name])[node])
841
842 - def call_impexp_status(self, node, names, 843 _def=_CALLS['impexp_status']):
844 """Wrapper for RPC call 'impexp_status' 845 846 Gets the status of an import or export 847 848 @note: This is a single-node call with a timeout of 5m 0s 849 @type node: string 850 @param node: Node name 851 @param names: Import/export names 852 853 """ 854 return (self._Call(_def, [node], [names])[node])
855
856 - def call_import_start(self, node, opts, instance, component, dest, 857 _def=_CALLS['import_start']):
858 """Wrapper for RPC call 'import_start' 859 860 Starts an import daemon 861 862 @note: This is a single-node call with a timeout of 15m 0s 863 @type node: string 864 @param node: Node name 865 @param dest: Import destination 866 867 """ 868 return (self._Call(_def, [node], [opts, instance, component, 869 dest])[node])
870
871 - def call_instance_balloon_memory(self, node, instance, memory, 872 _def=_CALLS['instance_balloon_memory']):
873 """Wrapper for RPC call 'instance_balloon_memory' 874 875 Modify the amount of an instance's runtime memory 876 877 @note: This is a single-node call with a timeout of 15m 0s 878 @type node: string 879 @param node: Node name 880 @param instance: Instance object 881 882 """ 883 return (self._Call(_def, [node], [instance, memory])[node])
884
885 - def call_instance_finalize_migration_dst(self, node, instance, info, 886 success, _def=_CALLS['instance_finalize_migration_dst']):
887 """Wrapper for RPC call 'instance_finalize_migration_dst' 888 889 Finalize any target-node migration specific operation 890 891 @note: This is a single-node call with a timeout of 15m 0s 892 @type node: string 893 @param node: Node name 894 @param instance: Instance object 895 @param info: Result for the call_migration_info call 896 @param success: Whether the migration was a success or failure 897 898 """ 899 return (self._Call(_def, [node], [instance, info, success])[node])
900
901 - def call_instance_finalize_migration_src(self, node, instance, 902 success, live, _def=_CALLS['instance_finalize_migration_src']):
903 """Wrapper for RPC call 'instance_finalize_migration_src' 904 905 Finalize the instance migration on the source node 906 907 @note: This is a single-node call with a timeout of 1h 0m 0s 908 @type node: string 909 @param node: Node name 910 @param instance: Instance object 911 @param success: Whether the migration succeeded or not 912 @param live: Whether the user requested a live migration or not 913 914 """ 915 return (self._Call(_def, [node], [instance, success, live])[node])
916
917 - def call_instance_get_migration_status(self, node, instance, 918 _def=_CALLS['instance_get_migration_status']):
919 """Wrapper for RPC call 'instance_get_migration_status' 920 921 Report migration status 922 923 @note: This is a single-node call with a timeout of 1h 0m 0s 924 @type node: string 925 @param node: Node name 926 @param instance: Instance object 927 928 """ 929 return (self._Call(_def, [node], [instance])[node])
930
931 - def call_instance_info(self, node, instance, hname, hvparams, 932 _def=_CALLS['instance_info']):
933 """Wrapper for RPC call 'instance_info' 934 935 Returns information about a single instance 936 937 @note: This is a single-node call with a timeout of 1m 0s 938 @type node: string 939 @param node: Node name 940 @param instance: Instance name 941 @param hname: Hypervisor type 942 @param hvparams: Hypervisor parameters 943 944 """ 945 return (self._Call(_def, [node], [instance, hname, hvparams])[node])
946
947 - def call_instance_list(self, node_list, hypervisor_list, hvparams, 948 _def=_CALLS['instance_list']):
949 """Wrapper for RPC call 'instance_list' 950 951 Returns the list of running instances on the given nodes 952 953 @note: This is a multi-node call with a timeout of 1m 0s 954 @type node_list: list of string 955 @param node_list: List of node names 956 @param hypervisor_list: Hypervisors to query for instances 957 @param hvparams: Hvparams of all hypervisors 958 959 """ 960 return (self._Call(_def, node_list, [hypervisor_list, hvparams]))
961
962 - def call_instance_metadata_modify(self, node, instance, 963 _def=_CALLS['instance_metadata_modify']):
964 """Wrapper for RPC call 'instance_metadata_modify' 965 966 Modify instance metadata 967 968 @note: This is a single-node call with a timeout of 1m 0s 969 @type node: string 970 @param node: Node name 971 @param instance: Instance object 972 973 """ 974 return (self._Call(_def, [node], [instance])[node])
975
976 - def call_instance_migratable(self, node, instance, 977 _def=_CALLS['instance_migratable']):
978 """Wrapper for RPC call 'instance_migratable' 979 980 Checks whether the given instance can be migrated 981 982 @note: This is a single-node call with a timeout of 15m 0s 983 @type node: string 984 @param node: Node name 985 @param instance: Instance object 986 987 """ 988 return (self._Call(_def, [node], [instance])[node])
989
990 - def call_instance_migrate(self, node, cluster_name, instance, target, 991 live, _def=_CALLS['instance_migrate']):
992 """Wrapper for RPC call 'instance_migrate' 993 994 Migrate an instance 995 996 @note: This is a single-node call with a timeout of 1h 0m 0s 997 @type node: string 998 @param node: Node name 999 @param cluster_name: Cluster name 1000 @param instance: Instance object 1001 @param target: Target node name 1002 @param live: Whether the migration should be done live or not 1003 1004 """ 1005 return (self._Call(_def, [node], [cluster_name, instance, target, 1006 live])[node])
1007
1008 - def call_instance_os_add(self, node, instance_osp, reinstall, debug, 1009 _def=_CALLS['instance_os_add']):
1010 """Wrapper for RPC call 'instance_os_add' 1011 1012 Installs an operative system onto an instance 1013 1014 @note: This is a single-node call with a timeout of 1d 0h 0m 0s 1015 @type node: string 1016 @param node: Node name 1017 @param instance_osp: Tuple: (target instance, temporary OS parameters 1018 overriding configuration) 1019 @param reinstall: Whether the instance is being reinstalled 1020 @param debug: Debug level for the OS install script to use 1021 1022 """ 1023 return (self._Call(_def, [node], [instance_osp, reinstall, 1024 debug])[node])
1025
1026 - def call_instance_reboot(self, node, inst, reboot_type, 1027 shutdown_timeout, reason, _def=_CALLS['instance_reboot']):
1028 """Wrapper for RPC call 'instance_reboot' 1029 1030 Returns the list of running instances on the given nodes 1031 1032 @note: This is a single-node call with a timeout of 15m 0s 1033 @type node: string 1034 @param node: Node name 1035 @param inst: Instance object 1036 @param reason: The reason for the reboot 1037 1038 """ 1039 return (self._Call(_def, [node], [inst, reboot_type, shutdown_timeout, 1040 reason])[node])
1041
1042 - def call_instance_run_rename(self, node, instance, old_name, debug, 1043 _def=_CALLS['instance_run_rename']):
1044 """Wrapper for RPC call 'instance_run_rename' 1045 1046 Run the OS rename script for an instance 1047 1048 @note: This is a single-node call with a timeout of 1h 0m 0s 1049 @type node: string 1050 @param node: Node name 1051 @param instance: Instance object 1052 1053 """ 1054 return (self._Call(_def, [node], [instance, old_name, debug])[node])
1055
1056 - def call_instance_shutdown(self, node, instance, timeout, reason, 1057 _def=_CALLS['instance_shutdown']):
1058 """Wrapper for RPC call 'instance_shutdown' 1059 1060 Stops an instance 1061 1062 @note: This is a single-node call with a timeout of 15m 0s 1063 @type node: string 1064 @param node: Node name 1065 @param instance: Instance object 1066 @param reason: The reason for the shutdown 1067 1068 """ 1069 return (self._Call(_def, [node], [instance, timeout, reason])[node])
1070
1071 - def call_instance_start(self, node, instance_hvp_bep, startup_paused, 1072 reason, _def=_CALLS['instance_start']):
1073 """Wrapper for RPC call 'instance_start' 1074 1075 Starts an instance 1076 1077 @note: This is a single-node call with a timeout of 15m 0s 1078 @type node: string 1079 @param node: Node name 1080 @param reason: The reason for the startup 1081 1082 """ 1083 return (self._Call(_def, [node], [instance_hvp_bep, startup_paused, 1084 reason])[node])
1085
1086 - def call_lv_list(self, node_list, vg_name, _def=_CALLS['lv_list']):
1087 """Wrapper for RPC call 'lv_list' 1088 1089 Gets the logical volumes present in a given volume group 1090 1091 @note: This is a multi-node call with a timeout of 1m 0s 1092 @type node_list: list of string 1093 @param node_list: List of node names 1094 1095 """ 1096 return (self._Call(_def, node_list, [vg_name]))
1097
1098 - def call_migration_info(self, node, instance, 1099 _def=_CALLS['migration_info']):
1100 """Wrapper for RPC call 'migration_info' 1101 1102 Gather the information necessary to prepare an instance migration 1103 1104 @note: This is a single-node call with a timeout of 15m 0s 1105 @type node: string 1106 @param node: Node name 1107 @param instance: Instance object 1108 1109 """ 1110 return (self._Call(_def, [node], [instance])[node])
1111
1112 - def call_node_configure_ovs(self, node, ovs_name, ovs_link, 1113 _def=_CALLS['node_configure_ovs']):
1114 """Wrapper for RPC call 'node_configure_ovs' 1115 1116 This will create and setup the OpenvSwitch 1117 1118 @note: This is a single-node call with a timeout of 15m 0s 1119 @type node: string 1120 @param node: Node name 1121 @param ovs_name: Name of the OpenvSwitch to create 1122 @param ovs_link: Link of the OpenvSwitch to the outside 1123 1124 """ 1125 return (self._Call(_def, [node], [ovs_name, ovs_link])[node])
1126
1127 - def call_node_crypto_tokens(self, node, token_request, 1128 _def=_CALLS['node_crypto_tokens']):
1129 """Wrapper for RPC call 'node_crypto_tokens' 1130 1131 Handle crypto tokens of the node. 1132 1133 @note: This is a single-node call with a timeout of 1h 0m 0s 1134 @type node: string 1135 @param node: Node name 1136 @param token_request: List of tuples of requested crypto token types, 1137 actions 1138 1139 """ 1140 return (self._Call(_def, [node], [token_request])[node])
1141
1142 - def call_node_demote_from_mc(self, node, 1143 _def=_CALLS['node_demote_from_mc']):
1144 """Wrapper for RPC call 'node_demote_from_mc' 1145 1146 Demote a node from the master candidate role 1147 1148 @note: This is a single-node call with a timeout of 5m 0s 1149 @type node: string 1150 @param node: Node name 1151 1152 """ 1153 return (self._Call(_def, [node], [])[node])
1154
1155 - def call_node_ensure_daemon(self, node_list, daemon, run, 1156 _def=_CALLS['node_ensure_daemon']):
1157 """Wrapper for RPC call 'node_ensure_daemon' 1158 1159 Ensure daemon is running on the node. 1160 1161 @note: This is a multi-node call with a timeout of 1m 0s 1162 @type node_list: list of string 1163 @param node_list: List of node names 1164 @param daemon: Daemon name 1165 @param run: Whether the daemon should be running or stopped 1166 1167 """ 1168 return (self._Call(_def, node_list, [daemon, run]))
1169
1170 - def call_node_has_ip_address(self, node, address, 1171 _def=_CALLS['node_has_ip_address']):
1172 """Wrapper for RPC call 'node_has_ip_address' 1173 1174 Checks if a node has the given IP address 1175 1176 @note: This is a single-node call with a timeout of 5m 0s 1177 @type node: string 1178 @param node: Node name 1179 @param address: IP address 1180 1181 """ 1182 return (self._Call(_def, [node], [address])[node])
1183
1184 - def call_node_info(self, node_list, storage_units, hv_specs, 1185 _def=_CALLS['node_info']):
1186 """Wrapper for RPC call 'node_info' 1187 1188 Return node information 1189 1190 @note: This is a multi-node call with a timeout of 1m 0s 1191 @type node_list: list of string 1192 @param node_list: List of node names 1193 @param storage_units: List of tuples '<storage_type>,<key>,[<param>]' 1194 to ask for disk space information; the parameter list varies 1195 depending on the storage_type 1196 @param hv_specs: List of hypervisor specification (name, hvparams) to 1197 ask for node information 1198 1199 """ 1200 return (self._Call(_def, node_list, [storage_units, hv_specs]))
1201
1202 - def call_node_powercycle(self, node, hypervisor, hvparams, 1203 _def=_CALLS['node_powercycle']):
1204 """Wrapper for RPC call 'node_powercycle' 1205 1206 Tries to powercycle a node 1207 1208 @note: This is a single-node call with a timeout of 15m 0s 1209 @type node: string 1210 @param node: Node name 1211 @param hypervisor: Hypervisor type 1212 @param hvparams: Hypervisor parameters 1213 1214 """ 1215 return (self._Call(_def, [node], [hypervisor, hvparams])[node])
1216
1217 - def call_node_ssh_key_add(self, node_list, node_uuid, node_name, 1218 potential_master_candidates, to_authorized_keys, to_public_keys, 1219 get_public_keys, _def=_CALLS['node_ssh_key_add']):
1220 """Wrapper for RPC call 'node_ssh_key_add' 1221 1222 Distribute a new node's public SSH key on the cluster. 1223 1224 @note: This is a multi-node call with a timeout of 5m 0s 1225 @type node_list: list of string 1226 @param node_list: List of node names 1227 @param node_uuid: UUID of the node whose key is distributed 1228 @param node_name: Name of the node whose key is distributed 1229 @param potential_master_candidates: Potential master candidates 1230 @param to_authorized_keys: Whether the node's key should be added to 1231 all nodes' 'authorized_keys' file 1232 @param to_public_keys: Whether the node's key should be added to all 1233 nodes' public key file 1234 @param get_public_keys: Whether the node should get the other nodes' 1235 public keys 1236 1237 """ 1238 return (self._Call(_def, node_list, [node_uuid, node_name, 1239 potential_master_candidates, to_authorized_keys, to_public_keys, 1240 get_public_keys]))
1241
1242 - def call_node_ssh_key_remove(self, node_list, node_uuid, node_name, 1243 master_candidate_uuids, potential_master_candidates, 1244 from_authorized_keys, from_public_keys, clear_authorized_keys, 1245 clear_public_keys, readd, _def=_CALLS['node_ssh_key_remove']):
1246 """Wrapper for RPC call 'node_ssh_key_remove' 1247 1248 Remove a node's SSH key from the other nodes' key files. 1249 1250 @note: This is a multi-node call with a timeout of 5m 0s 1251 @type node_list: list of string 1252 @param node_list: List of node names 1253 @param node_uuid: UUID of the node whose key is removed 1254 @param node_name: Name of the node whose key is removed 1255 @param master_candidate_uuids: List of UUIDs of master candidates. 1256 @param potential_master_candidates: Potential master candidates 1257 @param from_authorized_keys: If the key should be removed from the 1258 'authorized_keys' file. 1259 @param from_public_keys: If the key should be removed from the public 1260 key file. 1261 @param clear_authorized_keys: If the 'authorized_keys' file of the 1262 node should be cleared. 1263 @param clear_public_keys: If the 'ganeti_pub_keys' file of the node 1264 should be cleared. 1265 @param readd: Whether this is a readd operation. 1266 1267 """ 1268 return (self._Call(_def, node_list, [node_uuid, node_name, 1269 master_candidate_uuids, potential_master_candidates, 1270 from_authorized_keys, from_public_keys, clear_authorized_keys, 1271 clear_public_keys, readd]))
1272
1273 - def call_node_ssh_keys_renew(self, node_list, node_uuids, node_names, 1274 master_candidate_uuids, potential_master_candidates, 1275 _def=_CALLS['node_ssh_keys_renew']):
1276 """Wrapper for RPC call 'node_ssh_keys_renew' 1277 1278 Renew all SSH key pairs of all nodes nodes. 1279 1280 @note: This is a multi-node call with a timeout of 4h 0m 0s 1281 @type node_list: list of string 1282 @param node_list: List of node names 1283 @param node_uuids: UUIDs of the nodes whose key is renewed 1284 @param node_names: Names of the nodes whose key is renewed 1285 @param master_candidate_uuids: List of UUIDs of master candidates. 1286 @param potential_master_candidates: Potential master candidates 1287 1288 """ 1289 return (self._Call(_def, node_list, [node_uuids, node_names, 1290 master_candidate_uuids, potential_master_candidates]))
1291
1292 - def call_node_verify(self, node_list, checkdict, cluster_name, 1293 all_hvparams, node_groups, groups_cfg, _def=_CALLS['node_verify']):
1294 """Wrapper for RPC call 'node_verify' 1295 1296 Request verification of given parameters 1297 1298 @note: This is a multi-node call with a timeout of 15m 0s 1299 @type node_list: list of string 1300 @param node_list: List of node names 1301 @param checkdict: What to verify 1302 @param cluster_name: Cluster name 1303 @param all_hvparams: Dictionary mapping hypervisor names to hvparams 1304 @param node_groups: node names mapped to their group uuids 1305 @param groups_cfg: a dictionary mapping group uuids to their 1306 configuration 1307 1308 """ 1309 return (self._Call(_def, node_list, [checkdict, cluster_name, 1310 all_hvparams, node_groups, groups_cfg]))
1311
1312 - def call_node_volumes(self, node_list, _def=_CALLS['node_volumes']):
1313 """Wrapper for RPC call 'node_volumes' 1314 1315 Gets all volumes on node(s) 1316 1317 @note: This is a multi-node call with a timeout of 5m 0s 1318 @type node_list: list of string 1319 @param node_list: List of node names 1320 1321 """ 1322 return (self._Call(_def, node_list, []))
1323
1324 - def call_os_diagnose(self, node_list, _def=_CALLS['os_diagnose']):
1325 """Wrapper for RPC call 'os_diagnose' 1326 1327 Request a diagnose of OS definitions 1328 1329 @note: This is a multi-node call with a timeout of 5m 0s 1330 @type node_list: list of string 1331 @param node_list: List of node names 1332 1333 """ 1334 return (self._Call(_def, node_list, []))
1335
1336 - def call_os_export(self, node, instance, override_env, 1337 _def=_CALLS['os_export']):
1338 """Wrapper for RPC call 'os_export' 1339 1340 Export an OS for a given instance 1341 1342 @note: This is a single-node call with a timeout of 5m 0s 1343 @type node: string 1344 @param node: Node name 1345 1346 """ 1347 return (self._Call(_def, [node], [instance, override_env])[node])
1348
1349 - def call_os_validate(self, node_list, required, name, checks, params, 1350 force_variant, _def=_CALLS['os_validate']):
1351 """Wrapper for RPC call 'os_validate' 1352 1353 Run a validation routine for a given OS 1354 1355 @note: This is a multi-node call with a timeout of 5m 0s 1356 @type node_list: list of string 1357 @param node_list: List of node names 1358 1359 """ 1360 return (self._Call(_def, node_list, [required, name, checks, params, 1361 force_variant]))
1362
1363 - def call_restricted_command(self, node_list, cmd, 1364 _def=_CALLS['restricted_command']):
1365 """Wrapper for RPC call 'restricted_command' 1366 1367 Runs restricted command 1368 1369 @note: This is a multi-node call with a timeout of 1h 0m 0s 1370 @type node_list: list of string 1371 @param node_list: List of node names 1372 @param cmd: Command name 1373 1374 """ 1375 return (self._Call(_def, node_list, [cmd]))
1376
1377 - def call_run_oob(self, node, oob_program, command, remote_node, 1378 timeout, _def=_CALLS['run_oob']):
1379 """Wrapper for RPC call 'run_oob' 1380 1381 Runs out-of-band command 1382 1383 @note: This is a single-node call with a timeout of 15m 0s 1384 @type node: string 1385 @param node: Node name 1386 1387 """ 1388 return (self._Call(_def, [node], [oob_program, command, remote_node, 1389 timeout])[node])
1390
1391 - def call_set_watcher_pause(self, node_list, until, 1392 _def=_CALLS['set_watcher_pause']):
1393 """Wrapper for RPC call 'set_watcher_pause' 1394 1395 Set watcher pause end 1396 1397 @note: This is a multi-node call with a timeout of 1m 0s 1398 @type node_list: list of string 1399 @param node_list: List of node names 1400 1401 """ 1402 return (self._Call(_def, node_list, [until]))
1403
1404 - def call_storage_execute(self, node, su_name, su_args, name, op, 1405 _def=_CALLS['storage_execute']):
1406 """Wrapper for RPC call 'storage_execute' 1407 1408 Executes an operation on a storage unit 1409 1410 @note: This is a single-node call with a timeout of 15m 0s 1411 @type node: string 1412 @param node: Node name 1413 1414 """ 1415 return (self._Call(_def, [node], [su_name, su_args, name, op])[node])
1416
1417 - def call_storage_list(self, node_list, su_name, su_args, name, fields, 1418 _def=_CALLS['storage_list']):
1419 """Wrapper for RPC call 'storage_list' 1420 1421 Get list of storage units 1422 1423 @note: This is a multi-node call with a timeout of 15m 0s 1424 @type node_list: list of string 1425 @param node_list: List of node names 1426 1427 """ 1428 return (self._Call(_def, node_list, [su_name, su_args, name, fields]))
1429
1430 - def call_storage_modify(self, node, su_name, su_args, name, changes, 1431 _def=_CALLS['storage_modify']):
1432 """Wrapper for RPC call 'storage_modify' 1433 1434 Modify a storage unit 1435 1436 @note: This is a single-node call with a timeout of 15m 0s 1437 @type node: string 1438 @param node: Node name 1439 1440 """ 1441 return (self._Call(_def, [node], [su_name, su_args, name, 1442 changes])[node])
1443
1444 - def call_test_delay(self, node_list, duration, 1445 _def=_CALLS['test_delay']):
1446 """Wrapper for RPC call 'test_delay' 1447 1448 Sleep for a fixed time on given node(s) 1449 1450 @note: This is a multi-node call 1451 @type node_list: list of string 1452 @param node_list: List of node names 1453 1454 """ 1455 return (self._Call(_def, node_list, [duration]))
1456
1457 - def call_vg_list(self, node_list, _def=_CALLS['vg_list']):
1458 """Wrapper for RPC call 'vg_list' 1459 1460 Gets the volume group list 1461 1462 @note: This is a multi-node call with a timeout of 1m 0s 1463 @type node_list: list of string 1464 @param node_list: List of node names 1465 1466 """ 1467 return (self._Call(_def, node_list, []))
1468
1469 - def call_x509_cert_create(self, node, validity, 1470 _def=_CALLS['x509_cert_create']):
1471 """Wrapper for RPC call 'x509_cert_create' 1472 1473 Creates a new X509 certificate for SSL/TLS 1474 1475 @note: This is a single-node call with a timeout of 15m 0s 1476 @type node: string 1477 @param node: Node name 1478 @param validity: Validity in seconds 1479 1480 """ 1481 return (self._Call(_def, [node], [validity])[node])
1482
1483 - def call_x509_cert_remove(self, node, name, 1484 _def=_CALLS['x509_cert_remove']):
1485 """Wrapper for RPC call 'x509_cert_remove' 1486 1487 Removes a X509 certificate 1488 1489 @note: This is a single-node call with a timeout of 15m 0s 1490 @type node: string 1491 @param node: Node name 1492 @param name: Certificate name 1493 1494 """ 1495 return (self._Call(_def, [node], [name])[node])
1496 1497
1498 -class RpcClientDnsOnly(object):
1499 # E1101: Non-existent members 1500 # R0904: Too many public methods 1501 # pylint: disable=E1101,R0904 1502 _CALLS = rpc_defs.CALLS['RpcClientDnsOnly'] 1503
1504 - def call_node_verify_light(self, node_list, checkdict, cluster_name, 1505 hvparams, node_groups, groups_cfg, 1506 _def=_CALLS['node_verify_light']):
1507 """Wrapper for RPC call 'node_verify_light' 1508 1509 Request verification of given parameters 1510 1511 @note: This is a multi-node call with a timeout of 15m 0s 1512 @type node_list: list of string 1513 @param node_list: List of node names 1514 @param checkdict: What to verify 1515 @param cluster_name: Cluster name 1516 @param hvparams: Dictionary mapping hypervisor names to hvparams 1517 @param node_groups: node names mapped to their group uuids 1518 @param groups_cfg: a dictionary mapping group uuids to their 1519 configuration 1520 1521 """ 1522 return (self._Call(_def, node_list, [checkdict, cluster_name, 1523 hvparams, node_groups, groups_cfg]))
1524
1525 - def call_version(self, node_list, _def=_CALLS['version']):
1526 """Wrapper for RPC call 'version' 1527 1528 Query node version 1529 1530 @note: This is a multi-node call with a timeout of 1m 0s 1531 @type node_list: list of string 1532 @param node_list: List of node names 1533 1534 """ 1535 return (self._Call(_def, node_list, []))
1536 1537
1538 -class RpcClientJobQueue(object):
1539 # E1101: Non-existent members 1540 # R0904: Too many public methods 1541 # pylint: disable=E1101,R0904 1542 _CALLS = rpc_defs.CALLS['RpcClientJobQueue'] 1543
1544 - def call_jobqueue_purge(self, node, _def=_CALLS['jobqueue_purge']):
1545 """Wrapper for RPC call 'jobqueue_purge' 1546 1547 Purge job queue 1548 1549 @note: This is a single-node call with a timeout of 15m 0s 1550 @type node: string 1551 @param node: Node name 1552 1553 """ 1554 return (self._Call(_def, [node], [])[node])
1555
1556 - def call_jobqueue_rename(self, node_list, rename, 1557 _def=_CALLS['jobqueue_rename']):
1558 """Wrapper for RPC call 'jobqueue_rename' 1559 1560 Rename job queue file 1561 1562 @note: This is a multi-node call with a timeout of 1m 0s 1563 @type node_list: list of string 1564 @param node_list: List of node names 1565 1566 """ 1567 return (self._Call(_def, node_list, [rename]))
1568
1569 - def call_jobqueue_set_drain_flag(self, node_list, flag, 1570 _def=_CALLS['jobqueue_set_drain_flag']):
1571 """Wrapper for RPC call 'jobqueue_set_drain_flag' 1572 1573 Set job queue drain flag 1574 1575 @note: This is a multi-node call with a timeout of 1m 0s 1576 @type node_list: list of string 1577 @param node_list: List of node names 1578 1579 """ 1580 return (self._Call(_def, node_list, [flag]))
1581
1582 - def call_jobqueue_update(self, node_list, file_name, content, 1583 _def=_CALLS['jobqueue_update']):
1584 """Wrapper for RPC call 'jobqueue_update' 1585 1586 Update job queue file 1587 1588 @note: This is a multi-node call with a timeout of 1m 0s 1589 @type node_list: list of string 1590 @param node_list: List of node names 1591 1592 """ 1593 return (self._Call(_def, node_list, [file_name, content]))
1594