tests.unit._exit_scenarios Namespace Reference

Classes
class	DaemonPool
class	GenericHandler
class	MethodHandler

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

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

Function Documentation

connectivity_callback()

def tests.unit._exit_scenarios.connectivity_callback

(

connectivity

)

Definition at line 186 of file _exit_scenarios.py.

hang_partial_stream_stream()

def tests.unit._exit_scenarios.hang_partial_stream_stream	(		request_iterator,
			servicer_context
	)

Definition at line 88 of file _exit_scenarios.py.

hang_partial_stream_unary()

def tests.unit._exit_scenarios.hang_partial_stream_unary	(		request_iterator,
			servicer_context
	)

Definition at line 78 of file _exit_scenarios.py.

hang_partial_unary_stream()

def tests.unit._exit_scenarios.hang_partial_unary_stream	(		request,
			servicer_context
	)

Definition at line 68 of file _exit_scenarios.py.

hang_stream_stream()

def tests.unit._exit_scenarios.hang_stream_stream	(		request_iterator,
			servicer_context
	)

Definition at line 84 of file _exit_scenarios.py.

hang_stream_unary()

def tests.unit._exit_scenarios.hang_stream_unary	(		request_iterator,
			servicer_context
	)

Definition at line 74 of file _exit_scenarios.py.

hang_unary_stream()

def tests.unit._exit_scenarios.hang_unary_stream	(		request,
			servicer_context
	)

Definition at line 64 of file _exit_scenarios.py.

hang_unary_unary()

def tests.unit._exit_scenarios.hang_unary_unary	(		request,
			servicer_context
	)

Definition at line 60 of file _exit_scenarios.py.

infinite_request_iterator()

def tests.unit._exit_scenarios.infinite_request_iterator

(

)

Definition at line 159 of file _exit_scenarios.py.

Variable Documentation

action

tests.unit._exit_scenarios.action

Definition at line 170 of file _exit_scenarios.py.

args

tests.unit._exit_scenarios.args = parser.parse_args()

Definition at line 171 of file _exit_scenarios.py.

call

tests.unit._exit_scenarios.call

Definition at line 218 of file _exit_scenarios.py.

channel

tests.unit._exit_scenarios.channel = grpc.insecure_channel('localhost:12345')

Definition at line 184 of file _exit_scenarios.py.

connectivity_callback

def tests.unit._exit_scenarios.connectivity_callback

Definition at line 189 of file _exit_scenarios.py.

dest

tests.unit._exit_scenarios.dest

Definition at line 169 of file _exit_scenarios.py.

future

tests.unit._exit_scenarios.future = multi_callable.future(REQUEST)

Definition at line 217 of file _exit_scenarios.py.

handler

tests.unit._exit_scenarios.handler = GenericHandler()

Definition at line 206 of file _exit_scenarios.py.

IN_FLIGHT_PARTIAL_STREAM_STREAM_CALL

string tests.unit._exit_scenarios.IN_FLIGHT_PARTIAL_STREAM_STREAM_CALL = 'in_flight_partial_stream_stream_call'

Definition at line 39 of file _exit_scenarios.py.

IN_FLIGHT_PARTIAL_STREAM_UNARY_CALL

string tests.unit._exit_scenarios.IN_FLIGHT_PARTIAL_STREAM_UNARY_CALL = 'in_flight_partial_stream_unary_call'

Definition at line 38 of file _exit_scenarios.py.

IN_FLIGHT_PARTIAL_UNARY_STREAM_CALL

string tests.unit._exit_scenarios.IN_FLIGHT_PARTIAL_UNARY_STREAM_CALL = 'in_flight_partial_unary_stream_call'

Definition at line 37 of file _exit_scenarios.py.

IN_FLIGHT_STREAM_STREAM_CALL

string tests.unit._exit_scenarios.IN_FLIGHT_STREAM_STREAM_CALL = 'in_flight_stream_stream_call'

Definition at line 36 of file _exit_scenarios.py.

IN_FLIGHT_STREAM_UNARY_CALL

string tests.unit._exit_scenarios.IN_FLIGHT_STREAM_UNARY_CALL = 'in_flight_stream_unary_call'

Definition at line 35 of file _exit_scenarios.py.

IN_FLIGHT_UNARY_STREAM_CALL

string tests.unit._exit_scenarios.IN_FLIGHT_UNARY_STREAM_CALL = 'in_flight_unary_stream_call'

Definition at line 34 of file _exit_scenarios.py.

IN_FLIGHT_UNARY_UNARY_CALL

string tests.unit._exit_scenarios.IN_FLIGHT_UNARY_UNARY_CALL = 'in_flight_unary_unary_call'

Definition at line 33 of file _exit_scenarios.py.

method

dictionary tests.unit._exit_scenarios.method = TEST_TO_METHOD[args.scenario]

Definition at line 213 of file _exit_scenarios.py.

multi_callable

tests.unit._exit_scenarios.multi_callable = channel.unary_unary(method)

Definition at line 216 of file _exit_scenarios.py.

parser

tests.unit._exit_scenarios.parser = argparse.ArgumentParser()

Definition at line 166 of file _exit_scenarios.py.

PARTIAL_STREAM_STREAM

string tests.unit._exit_scenarios.PARTIAL_STREAM_STREAM = b'/test/PartialStreamStream'

Definition at line 47 of file _exit_scenarios.py.

PARTIAL_STREAM_UNARY

string tests.unit._exit_scenarios.PARTIAL_STREAM_UNARY = b'/test/PartialStreamUnary'

Definition at line 46 of file _exit_scenarios.py.

PARTIAL_UNARY_STREAM

string tests.unit._exit_scenarios.PARTIAL_UNARY_STREAM = b'/test/PartialUnaryStream'

Definition at line 45 of file _exit_scenarios.py.

POLL_CONNECTIVITY

string tests.unit._exit_scenarios.POLL_CONNECTIVITY = 'poll_connectivity'

Definition at line 32 of file _exit_scenarios.py.

POLL_CONNECTIVITY_NO_SERVER

string tests.unit._exit_scenarios.POLL_CONNECTIVITY_NO_SERVER = 'poll_connectivity_no_server'

Definition at line 31 of file _exit_scenarios.py.

port

tests.unit._exit_scenarios.port = server.add_insecure_port('[::]:0')

Definition at line 179 of file _exit_scenarios.py.

REQUEST

string tests.unit._exit_scenarios.REQUEST = b'request'

Definition at line 27 of file _exit_scenarios.py.

response_iterator

tests.unit._exit_scenarios.response_iterator = multi_callable(REQUEST)

Definition at line 222 of file _exit_scenarios.py.

result

tests.unit._exit_scenarios.result

Definition at line 218 of file _exit_scenarios.py.

RUNNING_SERVER

string tests.unit._exit_scenarios.RUNNING_SERVER = 'running_server'

Definition at line 30 of file _exit_scenarios.py.

server

tests.unit._exit_scenarios.server = grpc.server(DaemonPool(), options=(('grpc.so_reuseport', 0),))

Definition at line 174 of file _exit_scenarios.py.

STREAM_STREAM

string tests.unit._exit_scenarios.STREAM_STREAM = b'/test/StreamStream'

Definition at line 44 of file _exit_scenarios.py.

STREAM_UNARY

string tests.unit._exit_scenarios.STREAM_UNARY = b'/test/StreamUnary'

Definition at line 43 of file _exit_scenarios.py.

TEST_TO_METHOD

dictionary tests.unit._exit_scenarios.TEST_TO_METHOD

Initial value:

=  {
    IN_FLIGHT_UNARY_UNARY_CALL: UNARY_UNARY,
    IN_FLIGHT_UNARY_STREAM_CALL: UNARY_STREAM,
    IN_FLIGHT_STREAM_UNARY_CALL: STREAM_UNARY,
    IN_FLIGHT_STREAM_STREAM_CALL: STREAM_STREAM,
    IN_FLIGHT_PARTIAL_UNARY_STREAM_CALL: PARTIAL_UNARY_STREAM,
    IN_FLIGHT_PARTIAL_STREAM_UNARY_CALL: PARTIAL_STREAM_UNARY,
    IN_FLIGHT_PARTIAL_STREAM_STREAM_CALL: PARTIAL_STREAM_STREAM,
}

Definition at line 49 of file _exit_scenarios.py.

try_to_connect

tests.unit._exit_scenarios.try_to_connect

Definition at line 189 of file _exit_scenarios.py.

type

tests.unit._exit_scenarios.type

Definition at line 167 of file _exit_scenarios.py.

UNARY_STREAM

string tests.unit._exit_scenarios.UNARY_STREAM = b'/test/UnaryStream'

Definition at line 42 of file _exit_scenarios.py.

UNARY_UNARY

string tests.unit._exit_scenarios.UNARY_UNARY = b'/test/UnaryUnary'

Definition at line 41 of file _exit_scenarios.py.

UNSTARTED_SERVER

string tests.unit._exit_scenarios.UNSTARTED_SERVER = 'unstarted_server'

Definition at line 29 of file _exit_scenarios.py.

WAIT_TIME

int tests.unit._exit_scenarios.WAIT_TIME = 1000

Definition at line 25 of file _exit_scenarios.py.