grpc: xds_interop_client.py File Reference

Classes
class	xds_interop_client._ChannelConfiguration

class	xds_interop_client._LoadBalancerStatsServicer

class	xds_interop_client._MethodHandle

class	xds_interop_client._StatsWatcher

class	xds_interop_client._XdsUpdateClientConfigureServicer

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

None	xds_interop_client._handle_sigint (sig, frame)

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

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

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

None	xds_interop_client._run_single_channel (_ChannelConfiguration config)

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)

bool	xds_interop_client.bool_arg (str arg)

PerMethodMetadataType	xds_interop_client.parse_metadata_arg (str metadata_arg)

Sequence[str]	xds_interop_client.parse_rpc_arg (str rpc_arg)

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

	xds_interop_client._global_lock = threading.Lock()

	xds_interop_client._global_server = None

dictionary	xds_interop_client._METHOD_CAMEL_TO_CAPS_SNAKE

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

dictionary	xds_interop_client._METHOD_STR_TO_ENUM

	xds_interop_client._stop_event = threading.Event()

tuple	xds_interop_client._SUPPORTED_METHODS

	xds_interop_client.action

	xds_interop_client.args = parser.parse_args()

	xds_interop_client.console_handler = logging.StreamHandler()

	xds_interop_client.default

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

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

	xds_interop_client.help

	xds_interop_client.int

	xds_interop_client.logger = logging.getLogger()

tuple	xds_interop_client.metadata_help

	xds_interop_client.parser

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

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

	xds_interop_client.str

	xds_interop_client.type

Classes