|
| def | run_xds_tests._check_rpcs_in_flight (rpc_type, num_rpcs, threshold, threshold_fraction) |
| |
| def | run_xds_tests._verify_rpcs_to_given_backends (backends, timeout_sec, num_rpcs, allow_failures) |
| |
| def | run_xds_tests.add_backend_service (gcp, name) |
| |
| def | run_xds_tests.add_instance_group (gcp, zone, name, size) |
| |
| def | run_xds_tests.clean_up (gcp) |
| |
| def | run_xds_tests.compare_distributions (actual_distribution, expected_distribution, threshold) |
| |
| def | run_xds_tests.compare_expected_instances (stats, expected_instances) |
| |
| def | run_xds_tests.configure_client (rpc_types, metadata=[], timeout_sec=None) |
| |
| def | run_xds_tests.create_global_forwarding_rule (gcp, name, potential_ports, potential_ip_addresses=['0.0.0.0'], target_proxy=None) |
| |
| def | run_xds_tests.create_health_check (gcp, name) |
| |
| def | run_xds_tests.create_health_check_firewall_rule (gcp, name) |
| |
| def | run_xds_tests.create_instance_template (gcp, name, network, source_image, machine_type, startup_script) |
| |
| def | run_xds_tests.create_target_proxy (gcp, name, validate_for_proxyless=True, url_map=None) |
| |
| def | run_xds_tests.create_url_map (gcp, name, backend_service, host_name) |
| |
| def | run_xds_tests.delete_backend_service (gcp, backend_service) |
| |
| def | run_xds_tests.delete_backend_services (gcp) |
| |
| def | run_xds_tests.delete_firewall (gcp) |
| |
| def | run_xds_tests.delete_global_forwarding_rule (gcp, forwarding_rule_to_delete=None) |
| |
| def | run_xds_tests.delete_global_forwarding_rules (gcp) |
| |
| def | run_xds_tests.delete_health_check (gcp) |
| |
| def | run_xds_tests.delete_instance_groups (gcp) |
| |
| def | run_xds_tests.delete_instance_template (gcp) |
| |
| def | run_xds_tests.delete_target_proxies (gcp) |
| |
| def | run_xds_tests.delete_target_proxy (gcp, proxy_to_delete=None) |
| |
| def | run_xds_tests.delete_url_map (gcp, url_map_to_delete=None) |
| |
| def | run_xds_tests.delete_url_maps (gcp) |
| |
| def | run_xds_tests.get_backend_service (gcp, backend_service_name, record_error=True) |
| |
| def | run_xds_tests.get_client_accumulated_stats () |
| |
| def | run_xds_tests.get_client_stats (num_rpcs, timeout_sec) |
| |
| def | run_xds_tests.get_client_xds_config_dump () |
| |
| def | run_xds_tests.get_global_forwarding_rule (gcp, forwarding_rule_name, record_error=True) |
| |
| def | run_xds_tests.get_health_check (gcp, health_check_name) |
| |
| def | run_xds_tests.get_health_check_firewall_rule (gcp, firewall_name) |
| |
| def | run_xds_tests.get_instance_group (gcp, zone, instance_group_name) |
| |
| def | run_xds_tests.get_instance_names (gcp, instance_group) |
| |
| def | run_xds_tests.get_instance_template (gcp, template_name) |
| |
| def | run_xds_tests.get_serving_status (instance, service_port) |
| |
| def | run_xds_tests.get_startup_script (path_to_server_binary, service_port) |
| |
| def | run_xds_tests.get_target_proxy (gcp, target_proxy_name, record_error=True) |
| |
| def | run_xds_tests.get_url_map (gcp, url_map_name, record_error=True) |
| |
| def | run_xds_tests.is_primary_instance_group (gcp, instance_group) |
| |
| def | run_xds_tests.parse_port_range (port_arg) |
| |
| def | run_xds_tests.parse_test_cases (arg) |
| |
| def | run_xds_tests.patch_backend_service (gcp, backend_service, instance_groups, balancing_mode='UTILIZATION', max_rate=1, circuit_breakers=None) |
| |
| def | run_xds_tests.patch_url_map_backend_service (gcp, backend_service=None, services_with_weights=None, route_rules=None, url_map=None) |
| |
| def | run_xds_tests.patch_url_map_host_rule_with_port (gcp, name, backend_service, host_name) |
| |
| def | run_xds_tests.prepare_services_for_urlmap_tests (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group) |
| |
| def | run_xds_tests.resize_instance_group (gcp, instance_group, new_size, timeout_sec=_WAIT_FOR_OPERATION_SEC) |
| |
| def | run_xds_tests.set_serving_status (instances, service_port, serving) |
| |
| def | run_xds_tests.set_validate_for_proxyless (gcp, validate_for_proxyless) |
| |
| def | run_xds_tests.test_api_listener (gcp, backend_service, instance_group, alternate_backend_service) |
| |
| def | run_xds_tests.test_backends_restart (gcp, backend_service, instance_group) |
| |
| def | run_xds_tests.test_change_backend_service (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group) |
| |
| def | run_xds_tests.test_circuit_breaking (gcp, original_backend_service, instance_group, same_zone_instance_group) |
| |
| def | run_xds_tests.test_csds (gcp, original_backend_service, instance_group, server_uri) |
| |
| def | run_xds_tests.test_fault_injection (gcp, original_backend_service, instance_group) |
| |
| def | run_xds_tests.test_forwarding_rule_default_port (gcp, backend_service, instance_group) |
| |
| def | run_xds_tests.test_forwarding_rule_port_match (gcp, backend_service, instance_group) |
| |
| def | run_xds_tests.test_gentle_failover (gcp, backend_service, primary_instance_group, secondary_instance_group, swapped_primary_and_secondary=False) |
| |
| def | run_xds_tests.test_header_matching (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group) |
| |
| def | run_xds_tests.test_load_report_based_failover (gcp, backend_service, primary_instance_group, secondary_instance_group) |
| |
| def | run_xds_tests.test_metadata_filter (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group) |
| |
| def | run_xds_tests.test_path_matching (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group) |
| |
| def | run_xds_tests.test_ping_pong (gcp, backend_service, instance_group) |
| |
| def | run_xds_tests.test_remove_instance_group (gcp, backend_service, instance_group, same_zone_instance_group) |
| |
| def | run_xds_tests.test_round_robin (gcp, backend_service, instance_group) |
| |
| 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) |
| |
| 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) |
| |
| def | run_xds_tests.test_timeout (gcp, original_backend_service, instance_group) |
| |
| def | run_xds_tests.test_traffic_splitting (gcp, original_backend_service, instance_group, alternate_backend_service, same_zone_instance_group) |
| |
| def | run_xds_tests.wait_for_global_operation (gcp, operation, timeout_sec=_WAIT_FOR_OPERATION_SEC) |
| |
| def | run_xds_tests.wait_for_healthy_backends (gcp, backend_service, instance_group, timeout_sec=_WAIT_FOR_BACKEND_SEC) |
| |
| def | run_xds_tests.wait_for_instance_group_to_reach_expected_size (gcp, instance_group, expected_size, timeout_sec) |
| |
| def | run_xds_tests.wait_for_zone_operation (gcp, zone, operation, timeout_sec=_WAIT_FOR_OPERATION_SEC) |
| |
| def | run_xds_tests.wait_until_all_rpcs_go_to_given_backends (backends, timeout_sec, num_rpcs=_NUM_TEST_RPCS) |
| |
| def | run_xds_tests.wait_until_all_rpcs_go_to_given_backends_or_fail (backends, timeout_sec, num_rpcs=_NUM_TEST_RPCS) |
| |
| def | run_xds_tests.wait_until_no_rpcs_go_to_given_backends (backends, timeout_sec) |
| |
| def | run_xds_tests.wait_until_rpcs_in_flight (rpc_type, timeout_sec, num_rpcs, threshold) |
| |
|
| list | run_xds_tests._ADDITIONAL_TEST_CASES |
| |
| | run_xds_tests._ALPHA_TEST_CASES = frozenset(['timeout']) |
| |
| string | run_xds_tests._BASE_BACKEND_SERVICE_NAME = 'test-backend-service' |
| |
| string | run_xds_tests._BASE_FIREWALL_RULE_NAME = 'test-fw-rule' |
| |
| string | run_xds_tests._BASE_FORWARDING_RULE_NAME = 'test-forwarding-rule' |
| |
| string | run_xds_tests._BASE_HEALTH_CHECK_NAME = 'test-hc' |
| |
| string | run_xds_tests._BASE_INSTANCE_GROUP_NAME = 'test-ig' |
| |
| string | run_xds_tests._BASE_SERVICE_HOST = 'grpc-test' |
| |
| string | run_xds_tests._BASE_TARGET_PROXY_NAME = 'test-target-proxy' |
| |
| string | run_xds_tests._BASE_TEMPLATE_NAME = 'test-template' |
| |
| string | run_xds_tests._BASE_URL_MAP_NAME = 'test-map' |
| |
| string | run_xds_tests._BOOTSTRAP_TEMPLATE |
| |
| int | run_xds_tests._CONNECTION_TIMEOUT_SEC = 60 |
| |
| string | run_xds_tests._DEFAULT_PORT_RANGE = '8080:8280' |
| |
| int | run_xds_tests._DEFAULT_SERVICE_PORT = 80 |
| |
| int | run_xds_tests._GCP_API_RETRIES = 5 |
| |
| | run_xds_tests._INSTANCE_GROUP_SIZE = args.instance_group_size |
| |
| int | run_xds_tests._NUM_TEST_RPCS = 10 * args.qps |
| |
| string | run_xds_tests._PATH_MATCHER_NAME = 'path-matcher' |
| |
| string | run_xds_tests._SPONGE_LOG_NAME = 'sponge_log.log' |
| |
| string | run_xds_tests._SPONGE_XML_NAME = 'sponge_log.xml' |
| |
| list | run_xds_tests._TEST_CASES |
| |
| | run_xds_tests._TEST_LOG_BASE_DIR |
| |
| string | run_xds_tests._TEST_METADATA_KEY = 'xds_md' |
| |
| string | run_xds_tests._TEST_METADATA_NUMERIC_KEY = 'xds_md_numeric' |
| |
| string | run_xds_tests._TEST_METADATA_NUMERIC_VALUE = '159' |
| |
| string | run_xds_tests._TEST_METADATA_VALUE_EMPTY = 'empty_ytpme' |
| |
| string | run_xds_tests._TEST_METADATA_VALUE_UNARY = 'unary_yranu' |
| |
| list | run_xds_tests._TESTS_TO_FAIL_ON_RPC_FAILURE = ['ping_pong', 'round_robin'] |
| |
| list | run_xds_tests._TESTS_TO_RUN_MULTIPLE_RPCS = ['path_matching', 'header_matching'] |
| |
| list | run_xds_tests._TESTS_TO_SEND_METADATA = ['header_matching'] |
| |
| | run_xds_tests._V3_TEST_CASES = frozenset(['timeout', 'fault_injection', 'csds']) |
| |
| | run_xds_tests._WAIT_FOR_BACKEND_SEC = args.wait_for_backend_sec |
| |
| int | run_xds_tests._WAIT_FOR_OPERATION_SEC = 1200 |
| |
| int | run_xds_tests._WAIT_FOR_STATS_SEC = _WAIT_FOR_URL_MAP_PATCH_SEC |
| |
| int | run_xds_tests._WAIT_FOR_URL_MAP_PATCH_SEC = 600 |
| |
| | run_xds_tests.action |
| |
| | run_xds_tests.alpha_compute = None |
| |
| def | run_xds_tests.alternate_backend_service |
| |
| string | run_xds_tests.alternate_backend_service_name = _BASE_BACKEND_SERVICE_NAME + '-alternate' + gcp_suffix |
| |
| | run_xds_tests.argp = argparse.ArgumentParser(description='Run xDS interop tests on GCP') |
| |
| | run_xds_tests.args = argp.parse_args() |
| |
| def | run_xds_tests.backend_service = get_backend_service(gcp, backend_service_name) |
| |
| string | run_xds_tests.backend_service_name = _BASE_BACKEND_SERVICE_NAME + gcp_suffix |
| |
| | run_xds_tests.bootstrap_path = os.path.abspath(args.bootstrap_file) |
| |
| list | run_xds_tests.bootstrap_server_features = [] |
| |
| | run_xds_tests.client_cmd = shlex.split(client_cmd_formatted) |
| |
| | run_xds_tests.client_cmd_formatted |
| |
| | run_xds_tests.client_env = dict(os.environ) |
| |
| list | run_xds_tests.CLIENT_HOSTS = [] |
| |
| | run_xds_tests.client_process = None |
| |
| | run_xds_tests.compute |
| |
| | run_xds_tests.console_handler = logging.StreamHandler() |
| |
| | run_xds_tests.default |
| |
| | run_xds_tests.delete |
| |
| def | run_xds_tests.extra_backend_service |
| |
| string | run_xds_tests.extra_backend_service_name = _BASE_BACKEND_SERVICE_NAME + '-extra' + gcp_suffix |
| |
| string | run_xds_tests.fail_on_failed_rpc = '' |
| |
| list | run_xds_tests.failed_tests = [] |
| |
| string | run_xds_tests.firewall_name = _BASE_FIREWALL_RULE_NAME + gcp_suffix |
| |
| | run_xds_tests.formatter = logging.Formatter(fmt='%(asctime)s: %(levelname)-8s %(message)s') |
| |
| string | run_xds_tests.forwarding_rule_name = _BASE_FORWARDING_RULE_NAME + gcp_suffix |
| |
| string | run_xds_tests.forwarding_rule_name_2 = forwarding_rule_name + '2' |
| |
| | run_xds_tests.gcp = GcpState(compute, alpha_compute, args.project_id, args.project_num) |
| |
| | run_xds_tests.gcp_suffix = args.gcp_suffix |
| |
| | run_xds_tests.handlers |
| |
| string | run_xds_tests.health_check_name = _BASE_HEALTH_CHECK_NAME + gcp_suffix |
| |
| | run_xds_tests.help |
| |
| def | run_xds_tests.instance_group = get_instance_group(gcp, args.zone, instance_group_name) |
| |
| string | run_xds_tests.instance_group_name = _BASE_INSTANCE_GROUP_NAME + gcp_suffix |
| |
| | run_xds_tests.int |
| |
| | run_xds_tests.keep_resources = args.keep_gcp_resources |
| |
| | run_xds_tests.log_dir = os.path.join(_TEST_LOG_BASE_DIR, test_case) |
| |
| | run_xds_tests.logger = logging.getLogger() |
| |
| | run_xds_tests.message |
| |
| string | run_xds_tests.metadata_to_send |
| |
| def | run_xds_tests.more_extra_backend_service |
| |
| string | run_xds_tests.more_extra_backend_service_name = _BASE_BACKEND_SERVICE_NAME + '-more-extra' + gcp_suffix |
| |
| | run_xds_tests.multi_target |
| |
| int | run_xds_tests.num_attempts = 1 |
| |
| | run_xds_tests.original_grpc_trace = os.environ.pop('GRPC_TRACE', None) |
| |
| | run_xds_tests.original_grpc_verbosity = os.environ.pop('GRPC_VERBOSITY', None) |
| |
| | run_xds_tests.potential_service_ports = list(args.service_port_range) |
| |
| | run_xds_tests.record_error |
| |
| | run_xds_tests.result = jobset.JobResult() |
| |
| | run_xds_tests.returncode |
| |
| string | run_xds_tests.rpcs_to_send = '--rpc="UnaryCall,EmptyCall"' |
| |
| def | run_xds_tests.same_zone_instance_group |
| |
| string | run_xds_tests.same_zone_instance_group_name = _BASE_INSTANCE_GROUP_NAME + '-same-zone' + gcp_suffix |
| |
| def | run_xds_tests.secondary_zone_instance_group |
| |
| string | run_xds_tests.secondary_zone_instance_group_name = _BASE_INSTANCE_GROUP_NAME + '-secondary-zone' + gcp_suffix |
| |
| string | run_xds_tests.server_uri = service_host_name |
| |
| string | run_xds_tests.service_host_name = _BASE_SERVICE_HOST + gcp_suffix |
| |
| def | run_xds_tests.startup_script |
| |
| | run_xds_tests.state |
| |
| | run_xds_tests.suite_name |
| |
| string | run_xds_tests.target_proxy_name = _BASE_TARGET_PROXY_NAME + gcp_suffix |
| |
| string | run_xds_tests.target_proxy_name_2 = target_proxy_name + '2' |
| |
| string | run_xds_tests.template_name = _BASE_TEMPLATE_NAME + gcp_suffix |
| |
| | run_xds_tests.test_log_file = open(test_log_filename, 'w+') |
| |
| | run_xds_tests.test_log_filename = os.path.join(log_dir, _SPONGE_LOG_NAME) |
| |
| dictionary | run_xds_tests.test_results = {} |
| |
| | run_xds_tests.type |
| |
| string | run_xds_tests.url_map_name = _BASE_URL_MAP_NAME + gcp_suffix |
| |
| string | run_xds_tests.url_map_name_2 = url_map_name + '2' |
| |