Classes
class	_ChannelConfiguration

class	_LoadBalancerStatsServicer

class	_MethodHandle

class	_StatsWatcher

class	_XdsUpdateClientConfigureServicer

Functions
None	_cancel_all_rpcs (Mapping[int, Tuple[grpc.Future, str]] futures)

None	_handle_sigint (sig, frame)

None	_on_rpc_done (int rpc_id, grpc.Future future, str method, bool print_response)

None	_remove_completed_rpcs (Mapping[int, grpc.Future] futures, bool print_response)

None	_run (argparse.Namespace args, Sequence[str] methods, PerMethodMetadataType per_method_metadata)

None	_run_single_channel (_ChannelConfiguration config)

None	_start_rpc (str method, Sequence[Tuple[str, str]] metadata, int request_id, test_pb2_grpc.TestServiceStub stub, float timeout, Mapping[int, Tuple[grpc.Future, str]] futures)

bool	bool_arg (str arg)

PerMethodMetadataType	parse_metadata_arg (str metadata_arg)

Sequence[str]	parse_rpc_arg (str rpc_arg)

Variables
	_CONFIG_CHANGE_TIMEOUT = datetime.timedelta(milliseconds=500)

	_global_lock = threading.Lock()

	_global_server = None

dictionary	_METHOD_CAMEL_TO_CAPS_SNAKE

dictionary	_METHOD_ENUM_TO_STR = {v: k for k, v in _METHOD_STR_TO_ENUM.items()}

dictionary	_METHOD_STR_TO_ENUM

	_stop_event = threading.Event()

tuple	_SUPPORTED_METHODS

	action

	args = parser.parse_args()

	console_handler = logging.StreamHandler()

	default

	file_handler = logging.FileHandler(args.log_file, mode='a')

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

	help

	int

	logger = logging.getLogger()

tuple	metadata_help

	parser

	PerMethodMetadataType = Mapping[str, Sequence[Tuple[str, str]]]

string	rpc_help = "A comma-delimited list of RPC methods to run. Must be one of "

	str

	type

Function Documentation

◆ _cancel_all_rpcs()

None xds_interop_client._cancel_all_rpcs ( Mapping[int, Tuple[grpc.Future, str]] futures )

private

Definition at line 247 of file xds_interop_client.py.

◆ _handle_sigint()

None xds_interop_client._handle_sigint	(	sig,
		frame
	)

private

Definition at line 125 of file xds_interop_client.py.

◆ _on_rpc_done()

None xds_interop_client._on_rpc_done	(	int	rpc_id,
		grpc.Future	future,
		str	method,
		bool	print_response
	)

private

Definition at line 197 of file xds_interop_client.py.

◆ _remove_completed_rpcs()

None xds_interop_client._remove_completed_rpcs	(	Mapping[int, grpc.Future]	futures,
		bool	print_response
	)

private

Definition at line 235 of file xds_interop_client.py.

◆ _run()

None xds_interop_client._run	(	argparse.Namespace	args,
		Sequence[str]	methods,
		PerMethodMetadataType	per_method_metadata
	)

private

Definition at line 380 of file xds_interop_client.py.

◆ _run_single_channel()

None xds_interop_client._run_single_channel ( _ChannelConfiguration config )

private

Definition at line 276 of file xds_interop_client.py.

◆ _start_rpc()

None xds_interop_client._start_rpc	(	str	method,
		Sequence[Tuple[str, str]]	metadata,
		int	request_id,
		test_pb2_grpc.TestServiceStub	stub,
		float	timeout,
		Mapping[int, Tuple[grpc.Future, str]]	futures
	)

private

Definition at line 179 of file xds_interop_client.py.

◆ bool_arg()

bool xds_interop_client.bool_arg ( str arg )

Definition at line 433 of file xds_interop_client.py.

◆ parse_metadata_arg()

PerMethodMetadataType xds_interop_client.parse_metadata_arg ( str metadata_arg )

Definition at line 411 of file xds_interop_client.py.

◆ parse_rpc_arg()

Sequence[str] xds_interop_client.parse_rpc_arg ( str rpc_arg )

Definition at line 425 of file xds_interop_client.py.

Variable Documentation

◆ _CONFIG_CHANGE_TIMEOUT

xds_interop_client._CONFIG_CHANGE_TIMEOUT = datetime.timedelta(milliseconds=500)

private

Definition at line 60 of file xds_interop_client.py.

◆ _global_lock

xds_interop_client._global_lock = threading.Lock()

private

Definition at line 111 of file xds_interop_client.py.

◆ _global_server

xds_interop_client._global_server = None

private

Definition at line 115 of file xds_interop_client.py.

◆ _METHOD_CAMEL_TO_CAPS_SNAKE

dictionary xds_interop_client._METHOD_CAMEL_TO_CAPS_SNAKE

private

Initial value:

 =  {
     "UnaryCall": "UNARY_CALL",
     "EmptyCall": "EMPTY_CALL",
 }

Definition at line 46 of file xds_interop_client.py.

◆ _METHOD_ENUM_TO_STR

dictionary xds_interop_client._METHOD_ENUM_TO_STR = {v: k for k, v in _METHOD_STR_TO_ENUM.items()}

private

Definition at line 56 of file xds_interop_client.py.

◆ _METHOD_STR_TO_ENUM

dictionary xds_interop_client._METHOD_STR_TO_ENUM

private

Initial value:

 =  {
     "UnaryCall": messages_pb2.ClientConfigureRequest.UNARY_CALL,
     "EmptyCall": messages_pb2.ClientConfigureRequest.EMPTY_CALL,
 }

Definition at line 51 of file xds_interop_client.py.

◆ _stop_event

xds_interop_client._stop_event = threading.Event()

private

Definition at line 112 of file xds_interop_client.py.

◆ _SUPPORTED_METHODS

tuple xds_interop_client._SUPPORTED_METHODS

private

Initial value:

 =  (
     "UnaryCall",
     "EmptyCall",
 )

Definition at line 41 of file xds_interop_client.py.

◆ action

xds_interop_client.action

Definition at line 479 of file xds_interop_client.py.

◆ args

xds_interop_client.args = parser.parse_args()

Definition at line 493 of file xds_interop_client.py.

◆ console_handler

xds_interop_client.console_handler = logging.StreamHandler()

Definition at line 36 of file xds_interop_client.py.

◆ default

xds_interop_client.default

Definition at line 447 of file xds_interop_client.py.

◆ file_handler

xds_interop_client.file_handler = logging.FileHandler(args.log_file, mode='a')

Definition at line 498 of file xds_interop_client.py.

◆ formatter

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

Definition at line 37 of file xds_interop_client.py.

◆ help

xds_interop_client.help

Definition at line 449 of file xds_interop_client.py.

◆ int

xds_interop_client.int

Definition at line 113 of file xds_interop_client.py.

◆ logger

xds_interop_client.logger = logging.getLogger()

Definition at line 35 of file xds_interop_client.py.

◆ metadata_help

tuple xds_interop_client.metadata_help

Initial value:

 =  (
         "A comma-delimited list of 3-tuples of the form " +
         "METHOD:KEY:VALUE, e.g. " +
         "EmptyCall:key1:value1,UnaryCall:key2:value2,EmptyCall:k3:v3")

Definition at line 488 of file xds_interop_client.py.

◆ parser

xds_interop_client.parser

Initial value:

1 = argparse.ArgumentParser(

2 description='Run Python XDS interop client.')

Definition at line 443 of file xds_interop_client.py.

◆ PerMethodMetadataType

xds_interop_client.PerMethodMetadataType = Mapping[str, Sequence[Tuple[str, str]]]

Definition at line 58 of file xds_interop_client.py.

◆ rpc_help

string xds_interop_client.rpc_help = "A comma-delimited list of RPC methods to run. Must be one of "

Definition at line 484 of file xds_interop_client.py.

◆ str

xds_interop_client.str

Definition at line 487 of file xds_interop_client.py.

◆ type

xds_interop_client.type

Definition at line 448 of file xds_interop_client.py.

Classes

Functions

Variables

Function Documentation

◆ _cancel_all_rpcs()

◆ _handle_sigint()

◆ _on_rpc_done()

◆ _remove_completed_rpcs()

◆ _run()

◆ _run_single_channel()

◆ _start_rpc()

◆ bool_arg()

◆ parse_metadata_arg()

◆ parse_rpc_arg()

Variable Documentation

◆ _CONFIG_CHANGE_TIMEOUT

◆ _global_lock

◆ _global_server

◆ _METHOD_CAMEL_TO_CAPS_SNAKE

◆ _METHOD_ENUM_TO_STR

◆ _METHOD_STR_TO_ENUM

◆ _stop_event

◆ _SUPPORTED_METHODS

◆ action

◆ args

◆ console_handler

◆ default

◆ file_handler

◆ formatter

◆ help

◆ int

◆ logger

◆ metadata_help

◆ parser

◆ PerMethodMetadataType

◆ rpc_help

◆ str

◆ type