ganeti._generated

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, debug, verbose, _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 @param debug: Set loglevel of ssh calls to 'debug'. 1237 @param verbose: Set loglevel of ssh calls to 'verbose'. 1238 1239 """ 1240 return (self._Call(_def, node_list, [node_uuid, node_name, 1241 potential_master_candidates, to_authorized_keys, to_public_keys, 1242 get_public_keys, debug, verbose]))

1243

1244 - def call_node_ssh_key_remove(self, node_list, node_uuid, node_name, 1245 master_candidate_uuids, potential_master_candidates, 1246 from_authorized_keys, from_public_keys, clear_authorized_keys, 1247 clear_public_keys, readd, debug, verbose, 1248 _def=_CALLS['node_ssh_key_remove']):

1249 """Wrapper for RPC call 'node_ssh_key_remove' 1250 1251 Remove a node's SSH key from the other nodes' key files. 1252 1253 @note: This is a multi-node call with a timeout of 5m 0s 1254 @type node_list: list of string 1255 @param node_list: List of node names 1256 @param node_uuid: UUID of the node whose key is removed 1257 @param node_name: Name of the node whose key is removed 1258 @param master_candidate_uuids: List of UUIDs of master candidates. 1259 @param potential_master_candidates: Potential master candidates 1260 @param from_authorized_keys: If the key should be removed from the 1261 'authorized_keys' file. 1262 @param from_public_keys: If the key should be removed from the public 1263 key file. 1264 @param clear_authorized_keys: If the 'authorized_keys' file of the 1265 node should be cleared. 1266 @param clear_public_keys: If the 'ganeti_pub_keys' file of the node 1267 should be cleared. 1268 @param readd: Whether this is a readd operation. 1269 @param debug: Set loglevel of ssh calls to 'debug'. 1270 @param verbose: Set loglevel of ssh calls to 'verbose'. 1271 1272 """ 1273 return (self._Call(_def, node_list, [node_uuid, node_name, 1274 master_candidate_uuids, potential_master_candidates, 1275 from_authorized_keys, from_public_keys, clear_authorized_keys, 1276 clear_public_keys, readd, debug, verbose]))

1277

1278 - def call_node_ssh_key_remove_light(self, node_list, node_name, 1279 _def=_CALLS['node_ssh_key_remove_light']):

1280 """Wrapper for RPC call 'node_ssh_key_remove_light' 1281 1282 Remove a node's SSH key from the master's public key file. 1283 1284 @note: This is a multi-node call with a timeout of 5m 0s 1285 @type node_list: list of string 1286 @param node_list: List of node names 1287 @param node_name: Name of the node whose key is removed 1288 1289 """ 1290 return (self._Call(_def, node_list, [node_name]))

1291

1292 - def call_node_ssh_keys_renew(self, node_list, node_uuids, node_names, 1293 master_candidate_uuids, potential_master_candidates, old_key_type, 1294 new_key_type, new_key_bits, debug, verbose, 1295 _def=_CALLS['node_ssh_keys_renew']):

1296 """Wrapper for RPC call 'node_ssh_keys_renew' 1297 1298 Renew all SSH key pairs of all nodes nodes. 1299 1300 @note: This is a multi-node call with a timeout of 4h 0m 0s 1301 @type node_list: list of string 1302 @param node_list: List of node names 1303 @param node_uuids: UUIDs of the nodes whose key is renewed 1304 @param node_names: Names of the nodes whose key is renewed 1305 @param master_candidate_uuids: List of UUIDs of master candidates. 1306 @param potential_master_candidates: Potential master candidates 1307 @param old_key_type: The type of key previously used 1308 @param new_key_type: The type of key to generate 1309 @param new_key_bits: The length of the key to generate 1310 @param debug: Set logging of SSH update tool to 'debug'. 1311 @param verbose: Set logging of SSH update tool to 'info'. 1312 1313 """ 1314 return (self._Call(_def, node_list, [node_uuids, node_names, 1315 master_candidate_uuids, potential_master_candidates, old_key_type, 1316 new_key_type, new_key_bits, debug, verbose]))

1317

1318 - def call_node_verify(self, node_list, checkdict, cluster_name, 1319 all_hvparams, _def=_CALLS['node_verify']):

1320 """Wrapper for RPC call 'node_verify' 1321 1322 Request verification of given parameters 1323 1324 @note: This is a multi-node call with a timeout of 15m 0s 1325 @type node_list: list of string 1326 @param node_list: List of node names 1327 @param checkdict: What to verify 1328 @param cluster_name: Cluster name 1329 @param all_hvparams: Dictionary mapping hypervisor names to hvparams 1330 1331 """ 1332 return (self._Call(_def, node_list, [checkdict, cluster_name, 1333 all_hvparams]))

1334

1335 - def call_node_volumes(self, node_list, _def=_CALLS['node_volumes']):

1336 """Wrapper for RPC call 'node_volumes' 1337 1338 Gets all volumes on node(s) 1339 1340 @note: This is a multi-node call with a timeout of 5m 0s 1341 @type node_list: list of string 1342 @param node_list: List of node names 1343 1344 """ 1345 return (self._Call(_def, node_list, []))

1346

1347 - def call_os_diagnose(self, node_list, _def=_CALLS['os_diagnose']):

1348 """Wrapper for RPC call 'os_diagnose' 1349 1350 Request a diagnose of OS definitions 1351 1352 @note: This is a multi-node call with a timeout of 5m 0s 1353 @type node_list: list of string 1354 @param node_list: List of node names 1355 1356 """ 1357 return (self._Call(_def, node_list, []))

1358

1359 - def call_os_export(self, node, instance, override_env, 1360 _def=_CALLS['os_export']):

1361 """Wrapper for RPC call 'os_export' 1362 1363 Export an OS for a given instance 1364 1365 @note: This is a single-node call with a timeout of 5m 0s 1366 @type node: string 1367 @param node: Node name 1368 1369 """ 1370 return (self._Call(_def, [node], [instance, override_env])[node])

1371

1372 - def call_os_validate(self, node_list, required, name, checks, params, 1373 force_variant, _def=_CALLS['os_validate']):

1374 """Wrapper for RPC call 'os_validate' 1375 1376 Run a validation routine for a given OS 1377 1378 @note: This is a multi-node call with a timeout of 5m 0s 1379 @type node_list: list of string 1380 @param node_list: List of node names 1381 1382 """ 1383 return (self._Call(_def, node_list, [required, name, checks, params, 1384 force_variant]))

1385

1386 - def call_repair_command(self, node, cmd, inp, 1387 _def=_CALLS['repair_command']):

1388 """Wrapper for RPC call 'repair_command' 1389 1390 Runs repair command 1391 1392 @note: This is a single-node call with a timeout of 1h 0m 0s 1393 @type node: string 1394 @param node: Node name 1395 @param cmd: Command name 1396 @param inp: Input to be passed as stdin 1397 1398 """ 1399 return (self._Call(_def, [node], [cmd, inp])[node])

1400

1401 - def call_restricted_command(self, node_list, cmd, 1402 _def=_CALLS['restricted_command']):

1403 """Wrapper for RPC call 'restricted_command' 1404 1405 Runs restricted command 1406 1407 @note: This is a multi-node call with a timeout of 1h 0m 0s 1408 @type node_list: list of string 1409 @param node_list: List of node names 1410 @param cmd: Command name 1411 1412 """ 1413 return (self._Call(_def, node_list, [cmd]))

1414

1415 - def call_run_oob(self, node, oob_program, command, remote_node, 1416 timeout, _def=_CALLS['run_oob']):

1417 """Wrapper for RPC call 'run_oob' 1418 1419 Runs out-of-band command 1420 1421 @note: This is a single-node call with a timeout of 15m 0s 1422 @type node: string 1423 @param node: Node name 1424 1425 """ 1426 return (self._Call(_def, [node], [oob_program, command, remote_node, 1427 timeout])[node])

1428

1429 - def call_set_watcher_pause(self, node_list, until, 1430 _def=_CALLS['set_watcher_pause']):

1431 """Wrapper for RPC call 'set_watcher_pause' 1432 1433 Set watcher pause end 1434 1435 @note: This is a multi-node call with a timeout of 1m 0s 1436 @type node_list: list of string 1437 @param node_list: List of node names 1438 1439 """ 1440 return (self._Call(_def, node_list, [until]))

1441

1442 - def call_storage_execute(self, node, su_name, su_args, name, op, 1443 _def=_CALLS['storage_execute']):

1444 """Wrapper for RPC call 'storage_execute' 1445 1446 Executes an operation on a storage unit 1447 1448 @note: This is a single-node call with a timeout of 15m 0s 1449 @type node: string 1450 @param node: Node name 1451 1452 """ 1453 return (self._Call(_def, [node], [su_name, su_args, name, op])[node])

1454

1455 - def call_storage_list(self, node_list, su_name, su_args, name, fields, 1456 _def=_CALLS['storage_list']):

1457 """Wrapper for RPC call 'storage_list' 1458 1459 Get list of storage units 1460 1461 @note: This is a multi-node call with a timeout of 15m 0s 1462 @type node_list: list of string 1463 @param node_list: List of node names 1464 1465 """ 1466 return (self._Call(_def, node_list, [su_name, su_args, name, fields]))

1467

1468 - def call_storage_modify(self, node, su_name, su_args, name, changes, 1469 _def=_CALLS['storage_modify']):

1470 """Wrapper for RPC call 'storage_modify' 1471 1472 Modify a storage unit 1473 1474 @note: This is a single-node call with a timeout of 15m 0s 1475 @type node: string 1476 @param node: Node name 1477 1478 """ 1479 return (self._Call(_def, [node], [su_name, su_args, name, 1480 changes])[node])

1481

1482 - def call_test_delay(self, node_list, duration, 1483 _def=_CALLS['test_delay']):

1484 """Wrapper for RPC call 'test_delay' 1485 1486 Sleep for a fixed time on given node(s) 1487 1488 @note: This is a multi-node call 1489 @type node_list: list of string 1490 @param node_list: List of node names 1491 1492 """ 1493 return (self._Call(_def, node_list, [duration]))

1494

1495 - def call_vg_list(self, node_list, _def=_CALLS['vg_list']):

1496 """Wrapper for RPC call 'vg_list' 1497 1498 Gets the volume group list 1499 1500 @note: This is a multi-node call with a timeout of 1m 0s 1501 @type node_list: list of string 1502 @param node_list: List of node names 1503 1504 """ 1505 return (self._Call(_def, node_list, []))

1506

1507 - def call_x509_cert_create(self, node, validity, 1508 _def=_CALLS['x509_cert_create']):

1509 """Wrapper for RPC call 'x509_cert_create' 1510 1511 Creates a new X509 certificate for SSL/TLS 1512 1513 @note: This is a single-node call with a timeout of 15m 0s 1514 @type node: string 1515 @param node: Node name 1516 @param validity: Validity in seconds 1517 1518 """ 1519 return (self._Call(_def, [node], [validity])[node])

1520

1521 - def call_x509_cert_remove(self, node, name, 1522 _def=_CALLS['x509_cert_remove']):

1523 """Wrapper for RPC call 'x509_cert_remove' 1524 1525 Removes a X509 certificate 1526 1527 @note: This is a single-node call with a timeout of 15m 0s 1528 @type node: string 1529 @param node: Node name 1530 @param name: Certificate name 1531 1532 """ 1533 return (self._Call(_def, [node], [name])[node])

Source Code for Module ganeti._generated_rpc