xds_interop_client_test Namespace Reference

Classes
class	XdsInteropClientTest

Functions
Mapping[str, Mapping[int, int]]	_collect_stats (int stats_port, int duration)
def	_dump_stream (str process_name, str stream_name, tempfile.TemporaryFile stream)
def	_dump_streams (str process_name, tempfile.TemporaryFile stdout, tempfile.TemporaryFile stderr)
Mapping[str, Mapping[int, int]]	_index_accumulated_stats (messages_pb2.LoadBalancerAccumulatedStatsResponse response)
Set	_set_union (Iterable a, Iterable b)
Tuple[subprocess.Popen, tempfile.TemporaryFile, tempfile.TemporaryFile]	_start_python_with_args (str file, List[str] args)
def	_subtract_indexed_stats (Mapping[str, Mapping[int, int]] a, Mapping[str, Mapping[int, int]] b)

Variables
	_CLIENT_PATH = os.path.abspath(os.path.realpath(xds_interop_client.__file__))
int	_ITERATION_DURATION_SECONDS = 1
tuple	_METHODS
int	_NUM_CHANNELS = 20
int	_QPS = 100
	_SERVER_PATH = os.path.abspath(os.path.realpath(xds_interop_server.__file__))
int	_SUBPROCESS_TIMEOUT_SECONDS = 2
int	_TEST_ITERATIONS = 10
	verbosity

Function Documentation

_collect_stats()

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

private

Definition at line 106 of file xds_interop_client_test.py.

_dump_stream()

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

private

Definition at line 70 of file xds_interop_client_test.py.

_dump_streams()

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

private

Definition at line 77 of file xds_interop_client_test.py.

_index_accumulated_stats()

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

private

Definition at line 84 of file xds_interop_client_test.py.

_set_union()

Set xds_interop_client_test._set_union ( Iterable  a, Iterable  b  )

private

Definition at line 52 of file xds_interop_client_test.py.

_start_python_with_args()

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

private

Definition at line 59 of file xds_interop_client_test.py.

_subtract_indexed_stats()

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

private

Definition at line 95 of file xds_interop_client_test.py.

Variable Documentation

_CLIENT_PATH

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

private

Definition at line 36 of file xds_interop_client_test.py.

_ITERATION_DURATION_SECONDS

int xds_interop_client_test._ITERATION_DURATION_SECONDS = 1

private

Definition at line 48 of file xds_interop_client_test.py.

_METHODS

tuple xds_interop_client_test._METHODS

private

Initial value:

=  (
    (messages_pb2.ClientConfigureRequest.UNARY_CALL, "UNARY_CALL"),
    (messages_pb2.ClientConfigureRequest.EMPTY_CALL, "EMPTY_CALL"),
)

Definition at line 39 of file xds_interop_client_test.py.

_NUM_CHANNELS

int xds_interop_client_test._NUM_CHANNELS = 20

private

Definition at line 45 of file xds_interop_client_test.py.

_QPS

int xds_interop_client_test._QPS = 100

private

Definition at line 44 of file xds_interop_client_test.py.

_SERVER_PATH

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

private

Definition at line 37 of file xds_interop_client_test.py.

_SUBPROCESS_TIMEOUT_SECONDS

int xds_interop_client_test._SUBPROCESS_TIMEOUT_SECONDS = 2

private

Definition at line 49 of file xds_interop_client_test.py.

_TEST_ITERATIONS

int xds_interop_client_test._TEST_ITERATIONS = 10

private

Definition at line 47 of file xds_interop_client_test.py.

verbosity

xds_interop_client_test.verbosity

Definition at line 182 of file xds_interop_client_test.py.