Classes
class	GcpResource

class	GcpState

class	InstanceGroup

class	RpcDistributionError

Functions
def	_check_rpcs_in_flight (rpc_type, num_rpcs, threshold, threshold_fraction)

def	_verify_rpcs_to_given_backends (backends, timeout_sec, num_rpcs, allow_failures)

def	add_backend_service (gcp, name)

def	add_instance_group (gcp, zone, name, size)

def	clean_up (gcp)

def	compare_distributions (actual_distribution, expected_distribution, threshold)

def	compare_expected_instances (stats, expected_instances)

def	configure_client (rpc_types, metadata=[], timeout_sec=None)

def	create_global_forwarding_rule (gcp, name, potential_ports, potential_ip_addresses=['0.0.0.0'], target_proxy=None)

def	create_health_check (gcp, name)

def	create_health_check_firewall_rule (gcp, name)

def	create_instance_template (gcp, name, network, source_image, machine_type, startup_script)

def	create_target_proxy (gcp, name, validate_for_proxyless=True, url_map=None)

def	create_url_map (gcp, name, backend_service, host_name)

def	delete_backend_service (gcp, backend_service)

def	delete_backend_services (gcp)

def	delete_firewall (gcp)

def	delete_global_forwarding_rule (gcp, forwarding_rule_to_delete=None)

def	delete_global_forwarding_rules (gcp)

def	delete_health_check (gcp)

def	delete_instance_groups (gcp)

def	delete_instance_template (gcp)

def	delete_target_proxies (gcp)

def	delete_target_proxy (gcp, proxy_to_delete=None)

def	delete_url_map (gcp, url_map_to_delete=None)

def	delete_url_maps (gcp)

def	get_backend_service (gcp, backend_service_name, record_error=True)

def	get_client_accumulated_stats ()

def	get_client_stats (num_rpcs, timeout_sec)

def	get_client_xds_config_dump ()

def	get_global_forwarding_rule (gcp, forwarding_rule_name, record_error=True)

def	get_health_check (gcp, health_check_name)

def	get_health_check_firewall_rule (gcp, firewall_name)

def	get_instance_group (gcp, zone, instance_group_name)

def	get_instance_names (gcp, instance_group)

def	get_instance_template (gcp, template_name)

def	get_serving_status (instance, service_port)

def	get_startup_script (path_to_server_binary, service_port)

def	get_target_proxy (gcp, target_proxy_name, record_error=True)

def	get_url_map (gcp, url_map_name, record_error=True)

def	is_primary_instance_group (gcp, instance_group)

def	parse_port_range (port_arg)

def	parse_test_cases (arg)

def	patch_backend_service (gcp, backend_service, instance_groups, balancing_mode='UTILIZATION', max_rate=1, circuit_breakers=None)

def	patch_url_map_backend_service (gcp, backend_service=None, services_with_weights=None, route_rules=None, url_map=None)

def	patch_url_map_host_rule_with_port (gcp, name, backend_service, host_name)

def	prepare_services_for_urlmap_tests (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group)

def	resize_instance_group (gcp, instance_group, new_size, timeout_sec=_WAIT_FOR_OPERATION_SEC)

def	set_serving_status (instances, service_port, serving)

def	set_validate_for_proxyless (gcp, validate_for_proxyless)

def	test_api_listener (gcp, backend_service, instance_group, alternate_backend_service)

def	test_backends_restart (gcp, backend_service, instance_group)

def	test_change_backend_service (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group)

def	test_circuit_breaking (gcp, original_backend_service, instance_group, same_zone_instance_group)

def	test_csds (gcp, original_backend_service, instance_group, server_uri)

def	test_fault_injection (gcp, original_backend_service, instance_group)

def	test_forwarding_rule_default_port (gcp, backend_service, instance_group)

def	test_forwarding_rule_port_match (gcp, backend_service, instance_group)

def	test_gentle_failover (gcp, backend_service, primary_instance_group, secondary_instance_group, swapped_primary_and_secondary=False)

def	test_header_matching (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group)

def	test_load_report_based_failover (gcp, backend_service, primary_instance_group, secondary_instance_group)

def	test_metadata_filter (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group)

def	test_path_matching (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group)

def	test_ping_pong (gcp, backend_service, instance_group)

def	test_remove_instance_group (gcp, backend_service, instance_group, same_zone_instance_group)

def	test_round_robin (gcp, backend_service, instance_group)

def	test_secondary_locality_gets_no_requests_on_partial_primary_failure (gcp, backend_service, primary_instance_group, secondary_instance_group, swapped_primary_and_secondary=False)

def	test_secondary_locality_gets_requests_on_primary_failure (gcp, backend_service, primary_instance_group, secondary_instance_group, swapped_primary_and_secondary=False)

def	test_timeout (gcp, original_backend_service, instance_group)

def	test_traffic_splitting (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group)

def	wait_for_global_operation (gcp, operation, timeout_sec=_WAIT_FOR_OPERATION_SEC)

def	wait_for_healthy_backends (gcp, backend_service, instance_group, timeout_sec=_WAIT_FOR_BACKEND_SEC)

def	wait_for_instance_group_to_reach_expected_size (gcp, instance_group, expected_size, timeout_sec)

def	wait_for_zone_operation (gcp, zone, operation, timeout_sec=_WAIT_FOR_OPERATION_SEC)

def	wait_until_all_rpcs_go_to_given_backends (backends, timeout_sec, num_rpcs=_NUM_TEST_RPCS)

def	wait_until_all_rpcs_go_to_given_backends_or_fail (backends, timeout_sec, num_rpcs=_NUM_TEST_RPCS)

def	wait_until_no_rpcs_go_to_given_backends (backends, timeout_sec)

def	wait_until_rpcs_in_flight (rpc_type, timeout_sec, num_rpcs, threshold)

Variables
list	_ADDITIONAL_TEST_CASES

	_ALPHA_TEST_CASES = frozenset(['timeout'])

string	_BASE_BACKEND_SERVICE_NAME = 'test-backend-service'

string	_BASE_FIREWALL_RULE_NAME = 'test-fw-rule'

string	_BASE_FORWARDING_RULE_NAME = 'test-forwarding-rule'

string	_BASE_HEALTH_CHECK_NAME = 'test-hc'

string	_BASE_INSTANCE_GROUP_NAME = 'test-ig'

string	_BASE_SERVICE_HOST = 'grpc-test'

string	_BASE_TARGET_PROXY_NAME = 'test-target-proxy'

string	_BASE_TEMPLATE_NAME = 'test-template'

string	_BASE_URL_MAP_NAME = 'test-map'

string	_BOOTSTRAP_TEMPLATE

int	_CONNECTION_TIMEOUT_SEC = 60

string	_DEFAULT_PORT_RANGE = '8080:8280'

int	_DEFAULT_SERVICE_PORT = 80

int	_GCP_API_RETRIES = 5

	_INSTANCE_GROUP_SIZE = args.instance_group_size

int	_NUM_TEST_RPCS = 10 * args.qps

string	_PATH_MATCHER_NAME = 'path-matcher'

string	_SPONGE_LOG_NAME = 'sponge_log.log'

string	_SPONGE_XML_NAME = 'sponge_log.xml'

list	_TEST_CASES

	_TEST_LOG_BASE_DIR

string	_TEST_METADATA_KEY = 'xds_md'

string	_TEST_METADATA_NUMERIC_KEY = 'xds_md_numeric'

string	_TEST_METADATA_NUMERIC_VALUE = '159'

string	_TEST_METADATA_VALUE_EMPTY = 'empty_ytpme'

string	_TEST_METADATA_VALUE_UNARY = 'unary_yranu'

list	_TESTS_TO_FAIL_ON_RPC_FAILURE = ['ping_pong', 'round_robin']

list	_TESTS_TO_RUN_MULTIPLE_RPCS = ['path_matching', 'header_matching']

list	_TESTS_TO_SEND_METADATA = ['header_matching']

	_V3_TEST_CASES = frozenset(['timeout', 'fault_injection', 'csds'])

	_WAIT_FOR_BACKEND_SEC = args.wait_for_backend_sec

int	_WAIT_FOR_OPERATION_SEC = 1200

int	_WAIT_FOR_STATS_SEC = _WAIT_FOR_URL_MAP_PATCH_SEC

int	_WAIT_FOR_URL_MAP_PATCH_SEC = 600

	action

	alpha_compute = None

def	alternate_backend_service

string	alternate_backend_service_name = _BASE_BACKEND_SERVICE_NAME + '-alternate' + gcp_suffix

	argp = argparse.ArgumentParser(description='Run xDS interop tests on GCP')

	args = argp.parse_args()

def	backend_service = get_backend_service(gcp, backend_service_name)

string	backend_service_name = _BASE_BACKEND_SERVICE_NAME + gcp_suffix

	bootstrap_path = os.path.abspath(args.bootstrap_file)

list	bootstrap_server_features = []

	client_cmd = shlex.split(client_cmd_formatted)

	client_cmd_formatted

	client_env = dict(os.environ)

list	CLIENT_HOSTS = []

	client_process = None

	compute

	console_handler = logging.StreamHandler()

	default

	delete

def	extra_backend_service

string	extra_backend_service_name = _BASE_BACKEND_SERVICE_NAME + '-extra' + gcp_suffix

string	fail_on_failed_rpc = ''

list	failed_tests = []

string	firewall_name = _BASE_FIREWALL_RULE_NAME + gcp_suffix

	formatter = logging.Formatter(fmt='%(asctime)s: %(levelname)-8s %(message)s')

string	forwarding_rule_name = _BASE_FORWARDING_RULE_NAME + gcp_suffix

string	forwarding_rule_name_2 = forwarding_rule_name + '2'

	gcp = GcpState(compute, alpha_compute, args.project_id, args.project_num)

	gcp_suffix = args.gcp_suffix

	handlers

string	health_check_name = _BASE_HEALTH_CHECK_NAME + gcp_suffix

	help

def	instance_group = get_instance_group(gcp, args.zone, instance_group_name)

string	instance_group_name = _BASE_INSTANCE_GROUP_NAME + gcp_suffix

	int

	keep_resources = args.keep_gcp_resources

	log_dir = os.path.join(_TEST_LOG_BASE_DIR, test_case)

	logger = logging.getLogger()

	message

string	metadata_to_send

def	more_extra_backend_service

string	more_extra_backend_service_name = _BASE_BACKEND_SERVICE_NAME + '-more-extra' + gcp_suffix

	multi_target

int	num_attempts = 1

	original_grpc_trace = os.environ.pop('GRPC_TRACE', None)

	original_grpc_verbosity = os.environ.pop('GRPC_VERBOSITY', None)

	potential_service_ports = list(args.service_port_range)

	record_error

	result = jobset.JobResult()

	returncode

string	rpcs_to_send = '--rpc="UnaryCall,EmptyCall"'

def	same_zone_instance_group

string	same_zone_instance_group_name = _BASE_INSTANCE_GROUP_NAME + '-same-zone' + gcp_suffix

def	secondary_zone_instance_group

string	secondary_zone_instance_group_name = _BASE_INSTANCE_GROUP_NAME + '-secondary-zone' + gcp_suffix

string	server_uri = service_host_name

string	service_host_name = _BASE_SERVICE_HOST + gcp_suffix

def	startup_script

	state

	suite_name

string	target_proxy_name = _BASE_TARGET_PROXY_NAME + gcp_suffix

string	target_proxy_name_2 = target_proxy_name + '2'

string	template_name = _BASE_TEMPLATE_NAME + gcp_suffix

	test_log_file = open(test_log_filename, 'w+')

	test_log_filename = os.path.join(log_dir, _SPONGE_LOG_NAME)

dictionary	test_results = {}

	type

string	url_map_name = _BASE_URL_MAP_NAME + gcp_suffix

string	url_map_name_2 = url_map_name + '2'

Function Documentation

◆ _check_rpcs_in_flight()

def run_xds_tests._check_rpcs_in_flight	(	rpc_type,
		num_rpcs,
		threshold,
		threshold_fraction
	)

private

Definition at line 554 of file run_xds_tests.py.

◆ _verify_rpcs_to_given_backends()

def run_xds_tests._verify_rpcs_to_given_backends	(	backends,
		timeout_sec,
		num_rpcs,
		allow_failures
	)

private

Definition at line 459 of file run_xds_tests.py.

◆ add_backend_service()

def run_xds_tests.add_backend_service	(	gcp,
		name
	)

Definition at line 2559 of file run_xds_tests.py.

◆ add_instance_group()

def run_xds_tests.add_instance_group	(	gcp,
		zone,
		name,
		size
	)

Definition at line 2487 of file run_xds_tests.py.

◆ clean_up()

def run_xds_tests.clean_up ( gcp )

Definition at line 3139 of file run_xds_tests.py.

◆ compare_distributions()

def run_xds_tests.compare_distributions	(	actual_distribution,
		expected_distribution,
		threshold
	)

Compare if two distributions are similar.

Args:
  actual_distribution: A list of floats, contains the actual distribution.
  expected_distribution: A list of floats, contains the expected distribution.
  threshold: Number within [0,100], the threshold percentage by which the
    actual distribution can differ from the expected distribution.

Returns:
  The similarity between the distributions as a boolean. Returns true if the
  actual distribution lies within the threshold of the expected
  distribution, false otherwise.

Raises:
  ValueError: if threshold is not with in [0,100].
  Exception: containing detailed error messages.

Definition at line 570 of file run_xds_tests.py.

◆ compare_expected_instances()

def run_xds_tests.compare_expected_instances	(	stats,
		expected_instances
	)

Compare if stats have expected instances for each type of RPC.

Args:
  stats: LoadBalancerStatsResponse reported by interop client.
  expected_instances: a dict with key as the RPC type (string), value as
    the expected backend instances (list of strings).

Returns:
  Returns true if the instances are expected. False if not.

Definition at line 606 of file run_xds_tests.py.

◆ configure_client()

def run_xds_tests.configure_client	(	rpc_types,
		metadata = `[]`,
		timeout_sec = `None`
	)

Definition at line 427 of file run_xds_tests.py.

◆ create_global_forwarding_rule()

def run_xds_tests.create_global_forwarding_rule	(	gcp,
		name,
		potential_ports,
		potential_ip_addresses = `['0.0.0.0']`,
		target_proxy = `None`
	)

Definition at line 2648 of file run_xds_tests.py.

◆ create_health_check()

def run_xds_tests.create_health_check	(	gcp,
		name
	)

Definition at line 2515 of file run_xds_tests.py.

◆ create_health_check_firewall_rule()

def run_xds_tests.create_health_check_firewall_rule	(	gcp,
		name
	)

Definition at line 2541 of file run_xds_tests.py.

◆ create_instance_template()

def run_xds_tests.create_instance_template	(	gcp,
		name,
		network,
		source_image,
		machine_type,
		startup_script
	)

Definition at line 2445 of file run_xds_tests.py.

◆ create_target_proxy()

def run_xds_tests.create_target_proxy	(	gcp,
		name,
		validate_for_proxyless = `True`,
		url_map = `None`
	)

Definition at line 2618 of file run_xds_tests.py.

◆ create_url_map()

def run_xds_tests.create_url_map	(	gcp,
		name,
		backend_service,
		host_name
	)

Definition at line 2582 of file run_xds_tests.py.

◆ delete_backend_service()

def run_xds_tests.delete_backend_service	(	gcp,
		backend_service
	)

Definition at line 2871 of file run_xds_tests.py.

◆ delete_backend_services()

def run_xds_tests.delete_backend_services ( gcp )

Definition at line 2882 of file run_xds_tests.py.

◆ delete_firewall()

def run_xds_tests.delete_firewall ( gcp )

Definition at line 2887 of file run_xds_tests.py.

◆ delete_global_forwarding_rule()

def run_xds_tests.delete_global_forwarding_rule	(	gcp,
		forwarding_rule_to_delete = `None`
	)

Definition at line 2788 of file run_xds_tests.py.

◆ delete_global_forwarding_rules()

def run_xds_tests.delete_global_forwarding_rules ( gcp )

Definition at line 2809 of file run_xds_tests.py.

◆ delete_health_check()

def run_xds_tests.delete_health_check ( gcp )

Definition at line 2900 of file run_xds_tests.py.

◆ delete_instance_groups()

def run_xds_tests.delete_instance_groups ( gcp )

Definition at line 2911 of file run_xds_tests.py.

◆ delete_instance_template()

def run_xds_tests.delete_instance_template ( gcp )

Definition at line 2929 of file run_xds_tests.py.

◆ delete_target_proxies()

def run_xds_tests.delete_target_proxies ( gcp )

Definition at line 2841 of file run_xds_tests.py.

◆ delete_target_proxy()

def run_xds_tests.delete_target_proxy	(	gcp,
		proxy_to_delete = `None`
	)

Definition at line 2815 of file run_xds_tests.py.

◆ delete_url_map()

def run_xds_tests.delete_url_map	(	gcp,
		url_map_to_delete = `None`
	)

Definition at line 2847 of file run_xds_tests.py.

◆ delete_url_maps()

def run_xds_tests.delete_url_maps ( gcp )

Definition at line 2865 of file run_xds_tests.py.

◆ get_backend_service()

def run_xds_tests.get_backend_service	(	gcp,
		backend_service_name,
		record_error = `True`
	)

Definition at line 2710 of file run_xds_tests.py.

◆ get_client_accumulated_stats()

def run_xds_tests.get_client_accumulated_stats ( )

Definition at line 382 of file run_xds_tests.py.

◆ get_client_stats()

def run_xds_tests.get_client_stats	(	num_rpcs,
		timeout_sec
	)

Definition at line 359 of file run_xds_tests.py.

◆ get_client_xds_config_dump()

def run_xds_tests.get_client_xds_config_dump ( )

Definition at line 401 of file run_xds_tests.py.

◆ get_global_forwarding_rule()

def run_xds_tests.get_global_forwarding_rule	(	gcp,
		forwarding_rule_name,
		record_error = `True`
	)

Definition at line 2751 of file run_xds_tests.py.

◆ get_health_check()

def run_xds_tests.get_health_check	(	gcp,
		health_check_name
	)

Definition at line 2689 of file run_xds_tests.py.

◆ get_health_check_firewall_rule()

def run_xds_tests.get_health_check_firewall_rule	(	gcp,
		firewall_name
	)

Definition at line 2699 of file run_xds_tests.py.

◆ get_instance_group()

def run_xds_tests.get_instance_group	(	gcp,
		zone,
		instance_group_name
	)

Definition at line 2773 of file run_xds_tests.py.

◆ get_instance_names()

def run_xds_tests.get_instance_names	(	gcp,
		instance_group
	)

Definition at line 3117 of file run_xds_tests.py.

◆ get_instance_template()

def run_xds_tests.get_instance_template	(	gcp,
		template_name
	)

Definition at line 2763 of file run_xds_tests.py.

◆ get_serving_status()

def run_xds_tests.get_serving_status	(	instance,
		service_port
	)

Definition at line 2386 of file run_xds_tests.py.

◆ get_startup_script()

def run_xds_tests.get_startup_script	(	path_to_server_binary,
		service_port
	)

Definition at line 2426 of file run_xds_tests.py.

◆ get_target_proxy()

def run_xds_tests.get_target_proxy	(	gcp,
		target_proxy_name,
		record_error = `True`
	)

Definition at line 2734 of file run_xds_tests.py.

◆ get_url_map()

def run_xds_tests.get_url_map	(	gcp,
		url_map_name,
		record_error = `True`
	)

Definition at line 2723 of file run_xds_tests.py.

◆ is_primary_instance_group()

def run_xds_tests.is_primary_instance_group	(	gcp,
		instance_group
	)

Definition at line 2416 of file run_xds_tests.py.

◆ parse_port_range()

def run_xds_tests.parse_port_range ( port_arg )

Definition at line 129 of file run_xds_tests.py.

◆ parse_test_cases()

def run_xds_tests.parse_test_cases ( arg )

Definition at line 112 of file run_xds_tests.py.

◆ patch_backend_service()

def run_xds_tests.patch_backend_service	(	gcp,
		backend_service,
		instance_groups,
		balancing_mode = `'UTILIZATION'`,
		max_rate = `1`,
		circuit_breakers = `None`
	)

Definition at line 2942 of file run_xds_tests.py.

◆ patch_url_map_backend_service()

def run_xds_tests.patch_url_map_backend_service	(	gcp,
		backend_service = `None`,
		services_with_weights = `None`,
		route_rules = `None`,
		url_map = `None`
	)

Definition at line 2986 of file run_xds_tests.py.

◆ patch_url_map_host_rule_with_port()

def run_xds_tests.patch_url_map_host_rule_with_port	(	gcp,
		name,
		backend_service,
		host_name
	)

Definition at line 2604 of file run_xds_tests.py.

◆ prepare_services_for_urlmap_tests()

def run_xds_tests.prepare_services_for_urlmap_tests	(	gcp,
		original_backend_service,
		instance_group,
		alternate_backend_service,
		same_zone_instance_group
	)

This function prepares the services to be ready for tests that modifies
urlmaps.

Returns:
  Returns original and alternate backend names as lists of strings.

Definition at line 985 of file run_xds_tests.py.

◆ resize_instance_group()

def run_xds_tests.resize_instance_group	(	gcp,
		instance_group,
		new_size,
		timeout_sec = `_WAIT_FOR_OPERATION_SEC`
	)

Definition at line 2969 of file run_xds_tests.py.

◆ set_serving_status()

def run_xds_tests.set_serving_status	(	instances,
		service_port,
		serving
	)

Definition at line 2392 of file run_xds_tests.py.

◆ set_validate_for_proxyless()

def run_xds_tests.set_validate_for_proxyless	(	gcp,
		validate_for_proxyless
	)

Definition at line 2367 of file run_xds_tests.py.

◆ test_api_listener()

def run_xds_tests.test_api_listener	(	gcp,
		backend_service,
		instance_group,
		alternate_backend_service
	)

Definition at line 1169 of file run_xds_tests.py.

◆ test_backends_restart()

def run_xds_tests.test_backends_restart	(	gcp,
		backend_service,
		instance_group
	)

Definition at line 629 of file run_xds_tests.py.

◆ test_change_backend_service()

def run_xds_tests.test_change_backend_service	(	gcp,
		original_backend_service,
		instance_group,
		alternate_backend_service,
		same_zone_instance_group
	)

Definition at line 648 of file run_xds_tests.py.

◆ test_circuit_breaking()

def run_xds_tests.test_circuit_breaking	(	gcp,
		original_backend_service,
		instance_group,
		same_zone_instance_group
	)

Since backend service circuit_breakers configuration cannot be unset,
which causes trouble for restoring validate_for_proxy flag in target
proxy/global forwarding rule. This test uses dedicated backend sevices.
The url_map and backend services undergoes the following state changes:

Before test:
   original_backend_service -> [instance_group]
   extra_backend_service -> []
   more_extra_backend_service -> []

   url_map -> [original_backend_service]

In test:
   extra_backend_service (with circuit_breakers) -> [instance_group]
   more_extra_backend_service (with circuit_breakers) -> [same_zone_instance_group]

   url_map -> [extra_backend_service, more_extra_backend_service]

After test:
   original_backend_service -> [instance_group]
   extra_backend_service (with circuit_breakers) -> []
   more_extra_backend_service (with circuit_breakers) -> []

   url_map -> [original_backend_service]

Definition at line 1763 of file run_xds_tests.py.

◆ test_csds()

def run_xds_tests.test_csds	(	gcp,
		original_backend_service,
		instance_group,
		server_uri
	)

Definition at line 2245 of file run_xds_tests.py.

◆ test_fault_injection()

def run_xds_tests.test_fault_injection	(	gcp,
		original_backend_service,
		instance_group
	)

Definition at line 2057 of file run_xds_tests.py.

◆ test_forwarding_rule_default_port()

def run_xds_tests.test_forwarding_rule_default_port	(	gcp,
		backend_service,
		instance_group
	)

Definition at line 1276 of file run_xds_tests.py.

◆ test_forwarding_rule_port_match()

def run_xds_tests.test_forwarding_rule_port_match	(	gcp,
		backend_service,
		instance_group
	)

Definition at line 1243 of file run_xds_tests.py.

◆ test_gentle_failover()

def run_xds_tests.test_gentle_failover	(	gcp,
		backend_service,
		primary_instance_group,
		secondary_instance_group,
		swapped_primary_and_secondary = `False`
	)

Definition at line 676 of file run_xds_tests.py.

◆ test_header_matching()

def run_xds_tests.test_header_matching	(	gcp,
		original_backend_service,
		instance_group,
		alternate_backend_service,
		same_zone_instance_group
	)

Definition at line 1560 of file run_xds_tests.py.

◆ test_load_report_based_failover()

def run_xds_tests.test_load_report_based_failover	(	gcp,
		backend_service,
		primary_instance_group,
		secondary_instance_group
	)

Definition at line 739 of file run_xds_tests.py.

◆ test_metadata_filter()

def run_xds_tests.test_metadata_filter	(	gcp,
		original_backend_service,
		instance_group,
		alternate_backend_service,
		same_zone_instance_group
	)

Definition at line 1018 of file run_xds_tests.py.

◆ test_path_matching()

def run_xds_tests.test_path_matching	(	gcp,
		original_backend_service,
		instance_group,
		alternate_backend_service,
		same_zone_instance_group
	)

Definition at line 1415 of file run_xds_tests.py.

◆ test_ping_pong()

def run_xds_tests.test_ping_pong	(	gcp,
		backend_service,
		instance_group
	)

Definition at line 795 of file run_xds_tests.py.

◆ test_remove_instance_group()

def run_xds_tests.test_remove_instance_group	(	gcp,
		backend_service,
		instance_group,
		same_zone_instance_group
	)

Definition at line 803 of file run_xds_tests.py.

◆ test_round_robin()

def run_xds_tests.test_round_robin	(	gcp,
		backend_service,
		instance_group
	)

Definition at line 853 of file run_xds_tests.py.

◆ test_secondary_locality_gets_no_requests_on_partial_primary_failure()

def run_xds_tests.test_secondary_locality_gets_no_requests_on_partial_primary_failure	(	gcp,
		backend_service,
		primary_instance_group,
		secondary_instance_group,
		swapped_primary_and_secondary = `False`
	)

Definition at line 885 of file run_xds_tests.py.

◆ test_secondary_locality_gets_requests_on_primary_failure()

def run_xds_tests.test_secondary_locality_gets_requests_on_primary_failure	(	gcp,
		backend_service,
		primary_instance_group,
		secondary_instance_group,
		swapped_primary_and_secondary = `False`
	)

Definition at line 936 of file run_xds_tests.py.

◆ test_timeout()

def run_xds_tests.test_timeout	(	gcp,
		original_backend_service,
		instance_group
	)

Definition at line 1924 of file run_xds_tests.py.

◆ test_traffic_splitting()

def run_xds_tests.test_traffic_splitting	(	gcp,
		original_backend_service,
		instance_group,
		alternate_backend_service,
		same_zone_instance_group
	)

Definition at line 1337 of file run_xds_tests.py.

◆ wait_for_global_operation()

def run_xds_tests.wait_for_global_operation	(	gcp,
		operation,
		timeout_sec = `_WAIT_FOR_OPERATION_SEC`
	)

Definition at line 3045 of file run_xds_tests.py.

◆ wait_for_healthy_backends()

def run_xds_tests.wait_for_healthy_backends	(	gcp,
		backend_service,
		instance_group,
		timeout_sec = `_WAIT_FOR_BACKEND_SEC`
	)

Definition at line 3080 of file run_xds_tests.py.

◆ wait_for_instance_group_to_reach_expected_size()

def run_xds_tests.wait_for_instance_group_to_reach_expected_size	(	gcp,
		instance_group,
		expected_size,
		timeout_sec
	)

Definition at line 3031 of file run_xds_tests.py.

◆ wait_for_zone_operation()

def run_xds_tests.wait_for_zone_operation	(	gcp,
		zone,
		operation,
		timeout_sec = `_WAIT_FOR_OPERATION_SEC`
	)

Definition at line 3062 of file run_xds_tests.py.

◆ wait_until_all_rpcs_go_to_given_backends()

def run_xds_tests.wait_until_all_rpcs_go_to_given_backends	(	backends,
		timeout_sec,
		num_rpcs = `_NUM_TEST_RPCS`
	)

Definition at line 491 of file run_xds_tests.py.

◆ wait_until_all_rpcs_go_to_given_backends_or_fail()

def run_xds_tests.wait_until_all_rpcs_go_to_given_backends_or_fail	(	backends,
		timeout_sec,
		num_rpcs = `_NUM_TEST_RPCS`
	)

Definition at line 482 of file run_xds_tests.py.

◆ wait_until_no_rpcs_go_to_given_backends()

def run_xds_tests.wait_until_no_rpcs_go_to_given_backends	(	backends,
		timeout_sec
	)

Definition at line 500 of file run_xds_tests.py.

◆ wait_until_rpcs_in_flight()

def run_xds_tests.wait_until_rpcs_in_flight	(	rpc_type,
		timeout_sec,
		num_rpcs,
		threshold
	)

Block until the test client reaches the state with the given number
of RPCs being outstanding stably.

Args:
  rpc_type: A string indicating the RPC method to check for. Either
    'UnaryCall' or 'EmptyCall'.
  timeout_sec: Maximum number of seconds to wait until the desired state
    is reached.
  num_rpcs: Expected number of RPCs to be in-flight.
  threshold: Number within [0,100], the tolerable percentage by which
    the actual number of RPCs in-flight can differ from the expected number.

Definition at line 515 of file run_xds_tests.py.

Variable Documentation

◆ _ADDITIONAL_TEST_CASES

list run_xds_tests._ADDITIONAL_TEST_CASES

private

Initial value:

 =  [
     'circuit_breaking',
     'timeout',
     'fault_injection',
     'csds',
 ]

Definition at line 98 of file run_xds_tests.py.

◆ _ALPHA_TEST_CASES

run_xds_tests._ALPHA_TEST_CASES = frozenset(['timeout'])

private

Definition at line 109 of file run_xds_tests.py.

◆ _BASE_BACKEND_SERVICE_NAME

string run_xds_tests._BASE_BACKEND_SERVICE_NAME = 'test-backend-service'

private

Definition at line 348 of file run_xds_tests.py.

◆ _BASE_FIREWALL_RULE_NAME

string run_xds_tests._BASE_FIREWALL_RULE_NAME = 'test-fw-rule'

private

Definition at line 347 of file run_xds_tests.py.

◆ _BASE_FORWARDING_RULE_NAME

string run_xds_tests._BASE_FORWARDING_RULE_NAME = 'test-forwarding-rule'

private

Definition at line 352 of file run_xds_tests.py.

◆ _BASE_HEALTH_CHECK_NAME

string run_xds_tests._BASE_HEALTH_CHECK_NAME = 'test-hc'

private

Definition at line 346 of file run_xds_tests.py.

◆ _BASE_INSTANCE_GROUP_NAME

string run_xds_tests._BASE_INSTANCE_GROUP_NAME = 'test-ig'

private

Definition at line 345 of file run_xds_tests.py.

◆ _BASE_SERVICE_HOST

string run_xds_tests._BASE_SERVICE_HOST = 'grpc-test'

private

Definition at line 350 of file run_xds_tests.py.

◆ _BASE_TARGET_PROXY_NAME

string run_xds_tests._BASE_TARGET_PROXY_NAME = 'test-target-proxy'

private

Definition at line 351 of file run_xds_tests.py.

◆ _BASE_TEMPLATE_NAME

string run_xds_tests._BASE_TEMPLATE_NAME = 'test-template'

private

Definition at line 344 of file run_xds_tests.py.

◆ _BASE_URL_MAP_NAME

string run_xds_tests._BASE_URL_MAP_NAME = 'test-map'

private

Definition at line 349 of file run_xds_tests.py.

◆ _BOOTSTRAP_TEMPLATE

string run_xds_tests._BOOTSTRAP_TEMPLATE

private

Initial value:

 =  """
 {{
   "node": {{
     "id": "{node_id}",
     "metadata": {{
       "TRAFFICDIRECTOR_NETWORK_NAME": "%s",
       "com.googleapis.trafficdirector.config_time_trace": "TRUE"
     }},
     "locality": {{
       "zone": "%s"
     }}
   }},
   "xds_servers": [{{
     "server_uri": "%s",
     "channel_creds": [
       {{
         "type": "google_default",
         "config": {{}}
       }}
     ],
     "server_features": {server_features}
   }}]
 }}""" % (args.network.split('/')[-1], args.zone, args.xds_server)

Definition at line 305 of file run_xds_tests.py.

◆ _CONNECTION_TIMEOUT_SEC

int run_xds_tests._CONNECTION_TIMEOUT_SEC = 60

private

Definition at line 303 of file run_xds_tests.py.

◆ _DEFAULT_PORT_RANGE

string run_xds_tests._DEFAULT_PORT_RANGE = '8080:8280'

private

Definition at line 225 of file run_xds_tests.py.

◆ _DEFAULT_SERVICE_PORT

int run_xds_tests._DEFAULT_SERVICE_PORT = 80

private

Definition at line 298 of file run_xds_tests.py.

◆ _GCP_API_RETRIES

int run_xds_tests._GCP_API_RETRIES = 5

private

Definition at line 304 of file run_xds_tests.py.

◆ _INSTANCE_GROUP_SIZE

run_xds_tests._INSTANCE_GROUP_SIZE = args.instance_group_size

private

Definition at line 301 of file run_xds_tests.py.

◆ _NUM_TEST_RPCS

int run_xds_tests._NUM_TEST_RPCS = 10 * args.qps

private

Definition at line 302 of file run_xds_tests.py.

◆ _PATH_MATCHER_NAME

string run_xds_tests._PATH_MATCHER_NAME = 'path-matcher'

private

Definition at line 343 of file run_xds_tests.py.

◆ _SPONGE_LOG_NAME

string run_xds_tests._SPONGE_LOG_NAME = 'sponge_log.log'

private

Definition at line 355 of file run_xds_tests.py.

◆ _SPONGE_XML_NAME

string run_xds_tests._SPONGE_XML_NAME = 'sponge_log.xml'

private

Definition at line 356 of file run_xds_tests.py.

◆ _TEST_CASES

list run_xds_tests._TEST_CASES

private

Initial value:

 =  [
     'backends_restart',
     'change_backend_service',
     'gentle_failover',
     'load_report_based_failover',
     'ping_pong',
     'remove_instance_group',
     'round_robin',
     'secondary_locality_gets_no_requests_on_partial_primary_failure',
     'secondary_locality_gets_requests_on_primary_failure',
     'traffic_splitting',
     'path_matching',
     'header_matching',
     'api_listener',
     'forwarding_rule_port_match',
     'forwarding_rule_default_port',
     'metadata_filter',
 ]

Definition at line 75 of file run_xds_tests.py.

◆ _TEST_LOG_BASE_DIR

run_xds_tests._TEST_LOG_BASE_DIR

private

Initial value:

1 = os.path.join(os.path.dirname(os.path.abspath(__file__)),

2 '../../reports')

Definition at line 353 of file run_xds_tests.py.

◆ _TEST_METADATA_KEY

string run_xds_tests._TEST_METADATA_KEY = 'xds_md'

private

Definition at line 337 of file run_xds_tests.py.

◆ _TEST_METADATA_NUMERIC_KEY

string run_xds_tests._TEST_METADATA_NUMERIC_KEY = 'xds_md_numeric'

private

Definition at line 341 of file run_xds_tests.py.

◆ _TEST_METADATA_NUMERIC_VALUE

string run_xds_tests._TEST_METADATA_NUMERIC_VALUE = '159'

private

Definition at line 342 of file run_xds_tests.py.

◆ _TEST_METADATA_VALUE_EMPTY

string run_xds_tests._TEST_METADATA_VALUE_EMPTY = 'empty_ytpme'

private

Definition at line 339 of file run_xds_tests.py.

◆ _TEST_METADATA_VALUE_UNARY

string run_xds_tests._TEST_METADATA_VALUE_UNARY = 'unary_yranu'

private

Definition at line 338 of file run_xds_tests.py.

◆ _TESTS_TO_FAIL_ON_RPC_FAILURE

list run_xds_tests._TESTS_TO_FAIL_ON_RPC_FAILURE = ['ping_pong', 'round_robin']

private

Definition at line 332 of file run_xds_tests.py.

◆ _TESTS_TO_RUN_MULTIPLE_RPCS

list run_xds_tests._TESTS_TO_RUN_MULTIPLE_RPCS = ['path_matching', 'header_matching']

private

Definition at line 334 of file run_xds_tests.py.

◆ _TESTS_TO_SEND_METADATA

list run_xds_tests._TESTS_TO_SEND_METADATA = ['header_matching']

private

Definition at line 336 of file run_xds_tests.py.

◆ _V3_TEST_CASES

run_xds_tests._V3_TEST_CASES = frozenset(['timeout', 'fault_injection', 'csds'])

private

Definition at line 106 of file run_xds_tests.py.

◆ _WAIT_FOR_BACKEND_SEC

run_xds_tests._WAIT_FOR_BACKEND_SEC = args.wait_for_backend_sec

private

Definition at line 299 of file run_xds_tests.py.

◆ _WAIT_FOR_OPERATION_SEC

int run_xds_tests._WAIT_FOR_OPERATION_SEC = 1200

private

Definition at line 300 of file run_xds_tests.py.

◆ _WAIT_FOR_STATS_SEC

int run_xds_tests._WAIT_FOR_STATS_SEC = _WAIT_FOR_URL_MAP_PATCH_SEC

private

Definition at line 296 of file run_xds_tests.py.

◆ _WAIT_FOR_URL_MAP_PATCH_SEC

int run_xds_tests._WAIT_FOR_URL_MAP_PATCH_SEC = 600

private

Definition at line 291 of file run_xds_tests.py.

◆ action

run_xds_tests.action

Definition at line 165 of file run_xds_tests.py.

◆ alpha_compute

run_xds_tests.alpha_compute = None

Definition at line 3193 of file run_xds_tests.py.

◆ alternate_backend_service

def run_xds_tests.alternate_backend_service

Initial value:

1 = get_backend_service(

2 gcp, alternate_backend_service_name)

Definition at line 3256 of file run_xds_tests.py.

◆ alternate_backend_service_name

string run_xds_tests.alternate_backend_service_name = _BASE_BACKEND_SERVICE_NAME + '-alternate' + gcp_suffix

Definition at line 3235 of file run_xds_tests.py.

◆ argp

run_xds_tests.argp = argparse.ArgumentParser(description='Run xDS interop tests on GCP')

Definition at line 138 of file run_xds_tests.py.

◆ args

run_xds_tests.args = argp.parse_args()

Definition at line 277 of file run_xds_tests.py.

◆ backend_service

def run_xds_tests.backend_service = get_backend_service(gcp, backend_service_name)

Definition at line 3255 of file run_xds_tests.py.

◆ backend_service_name

string run_xds_tests.backend_service_name = _BASE_BACKEND_SERVICE_NAME + gcp_suffix

Definition at line 3234 of file run_xds_tests.py.

◆ bootstrap_path

run_xds_tests.bootstrap_path = os.path.abspath(args.bootstrap_file)

Definition at line 3327 of file run_xds_tests.py.

◆ bootstrap_server_features

list run_xds_tests.bootstrap_server_features = []

Definition at line 3317 of file run_xds_tests.py.

◆ client_cmd

run_xds_tests.client_cmd = shlex.split(client_cmd_formatted)

Definition at line 3416 of file run_xds_tests.py.

◆ client_cmd_formatted

run_xds_tests.client_cmd_formatted

Initial value:

 =  args.client_cmd.format(
                         server_uri=server_uri,
                         stats_port=args.stats_port,
                         qps=args.qps,
                         fail_on_failed_rpc=fail_on_failed_rpc,
                         rpcs_to_send=rpcs_to_send,
                         metadata_to_send=metadata_to_send)

Definition at line 3408 of file run_xds_tests.py.

◆ client_env

run_xds_tests.client_env = dict(os.environ)

Definition at line 3312 of file run_xds_tests.py.

◆ CLIENT_HOSTS

run_xds_tests.CLIENT_HOSTS = []

Definition at line 282 of file run_xds_tests.py.

◆ client_process

run_xds_tests.client_process = None

Definition at line 3368 of file run_xds_tests.py.

◆ compute

run_xds_tests.compute

Initial value:

1 = googleapiclient.discovery.build_from_document(

2 discovery_doc.read())

Definition at line 3196 of file run_xds_tests.py.

◆ console_handler

run_xds_tests.console_handler = logging.StreamHandler()

Definition at line 61 of file run_xds_tests.py.

◆ default

run_xds_tests.default

Definition at line 140 of file run_xds_tests.py.

◆ delete

run_xds_tests.delete

Definition at line 3329 of file run_xds_tests.py.

◆ extra_backend_service

def run_xds_tests.extra_backend_service

Initial value:

 =  get_backend_service(gcp,
                                                     extra_backend_service_name,
                                                     record_error=False)

Definition at line 3258 of file run_xds_tests.py.

◆ extra_backend_service_name

string run_xds_tests.extra_backend_service_name = _BASE_BACKEND_SERVICE_NAME + '-extra' + gcp_suffix

Definition at line 3236 of file run_xds_tests.py.

◆ fail_on_failed_rpc

string run_xds_tests.fail_on_failed_rpc = ''

Definition at line 3404 of file run_xds_tests.py.

◆ failed_tests

list run_xds_tests.failed_tests = []

Definition at line 3208 of file run_xds_tests.py.

◆ firewall_name

string run_xds_tests.firewall_name = _BASE_FIREWALL_RULE_NAME + gcp_suffix

Definition at line 3233 of file run_xds_tests.py.

◆ formatter

run_xds_tests.formatter = logging.Formatter(fmt='%(asctime)s: %(levelname)-8s %(message)s')

Definition at line 62 of file run_xds_tests.py.

◆ forwarding_rule_name

string run_xds_tests.forwarding_rule_name = _BASE_FORWARDING_RULE_NAME + gcp_suffix

Definition at line 3243 of file run_xds_tests.py.

◆ forwarding_rule_name_2

string run_xds_tests.forwarding_rule_name_2 = forwarding_rule_name + '2'

Definition at line 3244 of file run_xds_tests.py.

◆ gcp

run_xds_tests.gcp = GcpState(compute, alpha_compute, args.project_id, args.project_num)

Definition at line 3210 of file run_xds_tests.py.

◆ gcp_suffix

string run_xds_tests.gcp_suffix = args.gcp_suffix

Definition at line 3211 of file run_xds_tests.py.

◆ handlers

run_xds_tests.handlers

Definition at line 64 of file run_xds_tests.py.

◆ health_check_name

string run_xds_tests.health_check_name = _BASE_HEALTH_CHECK_NAME + gcp_suffix

Definition at line 3212 of file run_xds_tests.py.

◆ help

run_xds_tests.help

Definition at line 140 of file run_xds_tests.py.

◆ instance_group

def run_xds_tests.instance_group = get_instance_group(gcp, args.zone, instance_group_name)

Definition at line 3272 of file run_xds_tests.py.

◆ instance_group_name

string run_xds_tests.instance_group_name = _BASE_INSTANCE_GROUP_NAME + gcp_suffix

Definition at line 3246 of file run_xds_tests.py.

◆ int

run_xds_tests.int

Definition at line 185 of file run_xds_tests.py.

◆ keep_resources

bool run_xds_tests.keep_resources = args.keep_gcp_resources

Definition at line 3531 of file run_xds_tests.py.

◆ log_dir

run_xds_tests.log_dir = os.path.join(_TEST_LOG_BASE_DIR, test_case)

Definition at line 3363 of file run_xds_tests.py.

◆ logger

run_xds_tests.logger = logging.getLogger()

Definition at line 60 of file run_xds_tests.py.

◆ message

run_xds_tests.message

Definition at line 3499 of file run_xds_tests.py.

◆ metadata_to_send

string run_xds_tests.metadata_to_send

Initial value:

 =  '--metadata="EmptyCall:{keyE}:{valueE},UnaryCall:{keyU}:{valueU},UnaryCall:{keyNU}:{valueNU}"'.format(
                     keyE=_TEST_METADATA_KEY,
                     valueE=_TEST_METADATA_VALUE_EMPTY,
                     keyU=_TEST_METADATA_KEY,
                     valueU=_TEST_METADATA_VALUE_UNARY,
                     keyNU=_TEST_METADATA_NUMERIC_KEY,
                     valueNU=_TEST_METADATA_NUMERIC_VALUE)

Definition at line 3376 of file run_xds_tests.py.

◆ more_extra_backend_service

def run_xds_tests.more_extra_backend_service

Initial value:

1 = get_backend_service(

2 gcp, more_extra_backend_service_name, record_error=False)

Definition at line 3261 of file run_xds_tests.py.

◆ more_extra_backend_service_name

string run_xds_tests.more_extra_backend_service_name = _BASE_BACKEND_SERVICE_NAME + '-more-extra' + gcp_suffix

Definition at line 3237 of file run_xds_tests.py.

◆ multi_target

run_xds_tests.multi_target

Definition at line 3526 of file run_xds_tests.py.

◆ num_attempts

int run_xds_tests.num_attempts = 1

Definition at line 3218 of file run_xds_tests.py.

◆ original_grpc_trace

run_xds_tests.original_grpc_trace = os.environ.pop('GRPC_TRACE', None)

Definition at line 69 of file run_xds_tests.py.

◆ original_grpc_verbosity

run_xds_tests.original_grpc_verbosity = os.environ.pop('GRPC_VERBOSITY', None)

Definition at line 70 of file run_xds_tests.py.

◆ potential_service_ports

run_xds_tests.potential_service_ports = list(args.service_port_range)

Definition at line 3249 of file run_xds_tests.py.

◆ record_error

run_xds_tests.record_error

Definition at line 3266 of file run_xds_tests.py.

◆ result

run_xds_tests.result = jobset.JobResult()

Definition at line 3362 of file run_xds_tests.py.

◆ returncode

run_xds_tests.returncode

Definition at line 3494 of file run_xds_tests.py.

◆ rpcs_to_send

string run_xds_tests.rpcs_to_send = '--rpc="UnaryCall,EmptyCall"'

Definition at line 3371 of file run_xds_tests.py.

◆ same_zone_instance_group

def run_xds_tests.same_zone_instance_group

Initial value:

1 = get_instance_group(

2 gcp, args.zone, same_zone_instance_group_name)

Definition at line 3273 of file run_xds_tests.py.

◆ same_zone_instance_group_name

string run_xds_tests.same_zone_instance_group_name = _BASE_INSTANCE_GROUP_NAME + '-same-zone' + gcp_suffix

Definition at line 3247 of file run_xds_tests.py.

◆ secondary_zone_instance_group

def run_xds_tests.secondary_zone_instance_group

Initial value:

1 = get_instance_group(

2 gcp, args.secondary_zone, secondary_zone_instance_group_name)

Definition at line 3275 of file run_xds_tests.py.

◆ secondary_zone_instance_group_name

string run_xds_tests.secondary_zone_instance_group_name = _BASE_INSTANCE_GROUP_NAME + '-secondary-zone' + gcp_suffix

Definition at line 3248 of file run_xds_tests.py.

◆ server_uri

def run_xds_tests.server_uri = service_host_name

Definition at line 3320 of file run_xds_tests.py.

◆ service_host_name

string run_xds_tests.service_host_name = _BASE_SERVICE_HOST + gcp_suffix

Definition at line 3240 of file run_xds_tests.py.

◆ startup_script

def run_xds_tests.startup_script

Initial value:

1 = get_startup_script(args.path_to_server_binary,

2 gcp.service_port)

Definition at line 3295 of file run_xds_tests.py.

◆ state

run_xds_tests.state

Definition at line 3493 of file run_xds_tests.py.

◆ suite_name

run_xds_tests.suite_name

Definition at line 3525 of file run_xds_tests.py.

◆ target_proxy_name

string run_xds_tests.target_proxy_name = _BASE_TARGET_PROXY_NAME + gcp_suffix

Definition at line 3241 of file run_xds_tests.py.

◆ target_proxy_name_2

run_xds_tests.target_proxy_name_2 = target_proxy_name + '2'

Definition at line 3242 of file run_xds_tests.py.

◆ template_name

string run_xds_tests.template_name = _BASE_TEMPLATE_NAME + gcp_suffix

Definition at line 3245 of file run_xds_tests.py.

◆ test_log_file

run_xds_tests.test_log_file = open(test_log_filename, 'w+')

Definition at line 3367 of file run_xds_tests.py.

◆ test_log_filename

run_xds_tests.test_log_filename = os.path.join(log_dir, _SPONGE_LOG_NAME)

Definition at line 3366 of file run_xds_tests.py.

◆ test_results

dictionary run_xds_tests.test_results = {}

Definition at line 3207 of file run_xds_tests.py.

◆ type

run_xds_tests.type

Definition at line 152 of file run_xds_tests.py.

◆ url_map_name

string run_xds_tests.url_map_name = _BASE_URL_MAP_NAME + gcp_suffix

Definition at line 3238 of file run_xds_tests.py.

◆ url_map_name_2

run_xds_tests.url_map_name_2 = url_map_name + '2'

Definition at line 3239 of file run_xds_tests.py.

Classes

Functions

Variables

Function Documentation

◆ _check_rpcs_in_flight()

◆ _verify_rpcs_to_given_backends()

◆ add_backend_service()

◆ add_instance_group()

◆ clean_up()

◆ compare_distributions()

◆ compare_expected_instances()

◆ configure_client()

◆ create_global_forwarding_rule()

◆ create_health_check()

◆ create_health_check_firewall_rule()

◆ create_instance_template()

◆ create_target_proxy()

◆ create_url_map()

◆ delete_backend_service()

◆ delete_backend_services()

◆ delete_firewall()

◆ delete_global_forwarding_rule()

◆ delete_global_forwarding_rules()

◆ delete_health_check()

◆ delete_instance_groups()

◆ delete_instance_template()

◆ delete_target_proxies()

◆ delete_target_proxy()

◆ delete_url_map()

◆ delete_url_maps()

◆ get_backend_service()

◆ get_client_accumulated_stats()

◆ get_client_stats()

◆ get_client_xds_config_dump()

◆ get_global_forwarding_rule()

◆ get_health_check()

◆ get_health_check_firewall_rule()

◆ get_instance_group()

◆ get_instance_names()

◆ get_instance_template()

◆ get_serving_status()

◆ get_startup_script()

◆ get_target_proxy()

◆ get_url_map()

◆ is_primary_instance_group()

◆ parse_port_range()

◆ parse_test_cases()

◆ patch_backend_service()

◆ patch_url_map_backend_service()

◆ patch_url_map_host_rule_with_port()

◆ prepare_services_for_urlmap_tests()

◆ resize_instance_group()

◆ set_serving_status()

◆ set_validate_for_proxyless()

◆ test_api_listener()

◆ test_backends_restart()

◆ test_change_backend_service()

◆ test_circuit_breaking()

◆ test_csds()

◆ test_fault_injection()

◆ test_forwarding_rule_default_port()

◆ test_forwarding_rule_port_match()

◆ test_gentle_failover()

◆ test_header_matching()

◆ test_load_report_based_failover()

◆ test_metadata_filter()

◆ test_path_matching()

◆ test_ping_pong()

◆ test_remove_instance_group()

◆ test_round_robin()

◆ test_secondary_locality_gets_no_requests_on_partial_primary_failure()

◆ test_secondary_locality_gets_requests_on_primary_failure()

◆ test_timeout()

◆ test_traffic_splitting()

◆ wait_for_global_operation()

◆ wait_for_healthy_backends()

◆ wait_for_instance_group_to_reach_expected_size()

◆ wait_for_zone_operation()

◆ wait_until_all_rpcs_go_to_given_backends()

◆ wait_until_all_rpcs_go_to_given_backends_or_fail()