_exit_scenarios.py File Reference

Go to the source code of this file.

Classes
class	tests.unit._exit_scenarios.DaemonPool
class	tests.unit._exit_scenarios.GenericHandler
class	tests.unit._exit_scenarios.MethodHandler

Namespaces
	tests.unit._exit_scenarios

Functions
def	tests.unit._exit_scenarios.connectivity_callback (connectivity)
def	tests.unit._exit_scenarios.hang_partial_stream_stream (request_iterator, servicer_context)
def	tests.unit._exit_scenarios.hang_partial_stream_unary (request_iterator, servicer_context)
def	tests.unit._exit_scenarios.hang_partial_unary_stream (request, servicer_context)
def	tests.unit._exit_scenarios.hang_stream_stream (request_iterator, servicer_context)
def	tests.unit._exit_scenarios.hang_stream_unary (request_iterator, servicer_context)
def	tests.unit._exit_scenarios.hang_unary_stream (request, servicer_context)
def	tests.unit._exit_scenarios.hang_unary_unary (request, servicer_context)
def	tests.unit._exit_scenarios.infinite_request_iterator ()

Variables
	tests.unit._exit_scenarios.action
	tests.unit._exit_scenarios.args = parser.parse_args()
	tests.unit._exit_scenarios.call
	tests.unit._exit_scenarios.channel = grpc.insecure_channel('localhost:12345')
	tests.unit._exit_scenarios.connectivity_callback
	tests.unit._exit_scenarios.dest
	tests.unit._exit_scenarios.future = multi_callable.future(REQUEST)
	tests.unit._exit_scenarios.handler = GenericHandler()
string	tests.unit._exit_scenarios.IN_FLIGHT_PARTIAL_STREAM_STREAM_CALL = 'in_flight_partial_stream_stream_call'
string	tests.unit._exit_scenarios.IN_FLIGHT_PARTIAL_STREAM_UNARY_CALL = 'in_flight_partial_stream_unary_call'
string	tests.unit._exit_scenarios.IN_FLIGHT_PARTIAL_UNARY_STREAM_CALL = 'in_flight_partial_unary_stream_call'
string	tests.unit._exit_scenarios.IN_FLIGHT_STREAM_STREAM_CALL = 'in_flight_stream_stream_call'
string	tests.unit._exit_scenarios.IN_FLIGHT_STREAM_UNARY_CALL = 'in_flight_stream_unary_call'
string	tests.unit._exit_scenarios.IN_FLIGHT_UNARY_STREAM_CALL = 'in_flight_unary_stream_call'
string	tests.unit._exit_scenarios.IN_FLIGHT_UNARY_UNARY_CALL = 'in_flight_unary_unary_call'
dictionary	tests.unit._exit_scenarios.method = TEST_TO_METHOD[args.scenario]
	tests.unit._exit_scenarios.multi_callable = channel.unary_unary(method)
	tests.unit._exit_scenarios.parser = argparse.ArgumentParser()
string	tests.unit._exit_scenarios.PARTIAL_STREAM_STREAM = b'/test/PartialStreamStream'
string	tests.unit._exit_scenarios.PARTIAL_STREAM_UNARY = b'/test/PartialStreamUnary'
string	tests.unit._exit_scenarios.PARTIAL_UNARY_STREAM = b'/test/PartialUnaryStream'
string	tests.unit._exit_scenarios.POLL_CONNECTIVITY = 'poll_connectivity'
string	tests.unit._exit_scenarios.POLL_CONNECTIVITY_NO_SERVER = 'poll_connectivity_no_server'
	tests.unit._exit_scenarios.port = server.add_insecure_port('[::]:0')
string	tests.unit._exit_scenarios.REQUEST = b'request'
	tests.unit._exit_scenarios.response_iterator = multi_callable(REQUEST)
	tests.unit._exit_scenarios.result
string	tests.unit._exit_scenarios.RUNNING_SERVER = 'running_server'
	tests.unit._exit_scenarios.server = grpc.server(DaemonPool(), options=(('grpc.so_reuseport', 0),))
string	tests.unit._exit_scenarios.STREAM_STREAM = b'/test/StreamStream'
string	tests.unit._exit_scenarios.STREAM_UNARY = b'/test/StreamUnary'
dictionary	tests.unit._exit_scenarios.TEST_TO_METHOD
	tests.unit._exit_scenarios.try_to_connect
	tests.unit._exit_scenarios.type
string	tests.unit._exit_scenarios.UNARY_STREAM = b'/test/UnaryStream'
string	tests.unit._exit_scenarios.UNARY_UNARY = b'/test/UnaryUnary'
string	tests.unit._exit_scenarios.UNSTARTED_SERVER = 'unstarted_server'
int	tests.unit._exit_scenarios.WAIT_TIME = 1000