grpc: xds_interop_client_test.py File Reference

Classes
class	xds_interop_client_test.XdsInteropClientTest

Functions
Mapping[str, Mapping[int, int]]	xds_interop_client_test._collect_stats (int stats_port, int duration)

def	xds_interop_client_test._dump_stream (str process_name, str stream_name, tempfile.TemporaryFile stream)

def	xds_interop_client_test._dump_streams (str process_name, tempfile.TemporaryFile stdout, tempfile.TemporaryFile stderr)

Mapping[str, Mapping[int, int]]	xds_interop_client_test._index_accumulated_stats (messages_pb2.LoadBalancerAccumulatedStatsResponse response)

Set	xds_interop_client_test._set_union (Iterable a, Iterable b)

Tuple[subprocess.Popen, tempfile.TemporaryFile, tempfile.TemporaryFile]	xds_interop_client_test._start_python_with_args (str file, List[str] args)

def	xds_interop_client_test._subtract_indexed_stats (Mapping[str, Mapping[int, int]] a, Mapping[str, Mapping[int, int]] b)

Variables
	xds_interop_client_test._CLIENT_PATH = os.path.abspath(os.path.realpath(xds_interop_client.__file__))

int	xds_interop_client_test._ITERATION_DURATION_SECONDS = 1

tuple	xds_interop_client_test._METHODS

int	xds_interop_client_test._NUM_CHANNELS = 20

int	xds_interop_client_test._QPS = 100

	xds_interop_client_test._SERVER_PATH = os.path.abspath(os.path.realpath(xds_interop_server.__file__))

int	xds_interop_client_test._SUBPROCESS_TIMEOUT_SECONDS = 2

int	xds_interop_client_test._TEST_ITERATIONS = 10

	xds_interop_client_test.verbosity

Classes