Creates Client VM's :param jump_ssh: ssh connection :param num_clients: no.of clients :param image: VM image name :pa

Create <num_clients> clients :param num_clients: int, number of clients to create :param user: user to ssh :param user_data_f

Create a floating IP following Rally NeutronScenario._create_floatingip pattern. Rally ref: NeutronScenario._create_floatingip(floating_network)

Create annotations on Grafana dashboard for a given scenario :param start_timestamp: epoch time when scenario started running :param e

Create a listener. :param lb_id: ID of loadbalancer :param protocol_port: protocol port number for the listener :param max_att

Create <num_lbs> loadbalancers with specified <num_pools> <num_clients> per Loadbalancer. :param octavia_image: image ID or instance for serv

Create a member. :param client_ip: client ip address :param pool_id: ID of pool :param subnet_id: subnet ID for pool :

Create a network following Rally NeutronScenario._create_network pattern. Rally ref: NeutronScenario._create_network(network_create_args) Int

Create a pool. :param lb_id: ID of loadbalancer :param listener_id: ID of listener :param max_attempts: max retries

Create a port following Rally NeutronScenario._create_port pattern. Rally ref: NeutronScenario._create_port(network, port_create_args) Intern

Create a router following Rally NeutronScenario._create_router pattern. Rally ref: NeutronScenario._create_router(router_create_args) Interna

Create a security group following Rally NeutronScenario._create_security_group pattern. Rally ref: NeutronScenario._create_security_group(**secur

Create a security group rule following Rally pattern. Rally ref: NeutronScenario._create_security_group_rule( security_group_id, **securi

Create a subnet following Rally NeutronScenario._create_subnet pattern. Rally ref: NeutronScenario._create_subnet(network, subnet_create_args)

Delete a floating IP. Rally ref: NeutronScenario._delete_floating_ip(floating_ip) Internally calls: clients("neutron").delete_floatingip(fip_

Deletes <delete_num_lbs> loadbalancers randomly with associated resources :param delete_num_lbs: number of loadbalancers to delete

Deletes members from a random loadbalancer :param delete_num_members: number of members to delete

Delete a network following Rally NeutronScenario._delete_network pattern. Rally ref: NeutronScenario._delete_network(network) Internally call

Delete a port. Rally ref: NeutronScenario._delete_port(port) Internally calls: clients("neutron").delete_port(port_id)

Delete a router. Rally ref: NeutronScenario._delete_router(router) Internally calls: clients("neutron").delete_router(router_id)

Delete a security group following Rally NeutronScenario._delete_security_group pattern. Rally ref: NeutronScenario._delete_security_group(securit

Delete a server following Rally NovaScenario._delete_server pattern. Rally ref: NovaScenario._delete_server(server, force=False) Internally c

Delete a subnet. Rally ref: NeutronScenario._delete_subnet(subnet) Internally calls: clients("neutron").delete_subnet(subnet_id)

Delete <<subport_count>> subports from <<num_trunks>> randomly chosen trunks :param num_trunks: int, number of trunks to be randomly chosen

Detach a volume from a server following Rally NovaScenario._detach_volume pattern. Rally ref: NovaScenario._detach_volume(server, volume) Int

Dispatch a value to collectd

Dispatch a value to collectd

Dispatch a value to collectd

Execute single operation step Args: step (dict): Step definition with operation and args step_index (int): Index of t

Execute scenario steps sequentially with state management Args: steps (list): List of step definitions scenario_name

Find the leader pod in a RAFT cluster. Discovers pods by prefix, runs a status command on each via oc exec, and identifies the leader by matc

Generate csv files from pandas dataframe :param csv_files_path: str, path of directory to generate csv files :param df_dict: dict, dict of dat

Return combined handler map from all project modules. Args: workflow_instance: Workflow instance providing os_clients, logger, state

Complete duration data is stored in dict format to increase efficiency of operations. Rally add_output() function expects a list as input. Thi

Get list of atomic actions which occur more than once in an iteration :param atomic_actions: list, self.atomic_actions() from a rally scenario

Return handler function for operation type Args: operation_type (str): Operation type (e.g., 'nova.boot_server',

Get router for a given trunk :param trunk: dict, trunk details :returns: router object

Index step result to Elasticsearch Args: step (dict): Step definition step_index (int): Index of the step

Initialize OpenStack clients using rally_openstack.osclients. Loads credentials from the same source files used to create the Rally d

Installs openshift cluster on openstack

List flavors following Rally NovaScenario._list_flavors pattern. Rally ref: NovaScenario._list_flavors() Internally calls: clients("nova").fl

List floating IPs following Rally NeutronScenario._list_floating_ips pattern. Rally ref: NeutronScenario._list_floating_ips(**kwargs) Interna

List hypervisors following Rally NovaScenario._list_hypervisors pattern. Rally ref: NovaScenario._list_hypervisors() Internally calls: client

List all locks in database :returns: list, list of lock dictionaries

List networks following Rally NeutronScenario._list_networks pattern. Rally ref: NeutronScenario._list_networks(**kwargs) Internally calls: c

List servers following Rally NovaScenario._list_servers pattern. Rally ref: NovaScenario._list_servers(detailed=True) Internally calls: clien

Log a message. Args: wf: Workflow instance args (dict): Arguments with 'message' key step (dict): Full step definition

Log error with iteration number :param msg: str, message to log

Simulate pods with floating ips using subports on trunks and VMs :param ext_net_id: external network ID for floating IP creation :para