Classes
class	TestCase

Functions
def	_cancel_after_begin (test_pb2_grpc.TestServiceStub stub)

def	_cancel_after_first_response (test_pb2_grpc.TestServiceStub stub)

None	_client_streaming (test_pb2_grpc.TestServiceStub stub)

def	_compute_engine_creds (test_pb2_grpc.TestServiceStub stub, argparse.Namespace args)

def	_custom_metadata (test_pb2_grpc.TestServiceStub stub)

def	_empty_stream (test_pb2_grpc.TestServiceStub stub)

None	_empty_unary (test_pb2_grpc.TestServiceStub stub)

None	_expect_status_code (aio.Call call, grpc.StatusCode expected_code)

None	_expect_status_details (aio.Call call, str expected_details)

def	_jwt_token_creds (test_pb2_grpc.TestServiceStub stub)

None	_large_unary (test_pb2_grpc.TestServiceStub stub)

messages_pb2.SimpleResponse	_large_unary_common_behavior (test_pb2_grpc.TestServiceStub stub, bool fill_username, bool fill_oauth_scope, Optional[grpc.CallCredentials] call_credentials)

def	_oauth2_auth_token (test_pb2_grpc.TestServiceStub stub, argparse.Namespace args)

def	_per_rpc_creds (test_pb2_grpc.TestServiceStub stub, argparse.Namespace args)

None	_ping_pong (test_pb2_grpc.TestServiceStub stub)

None	_server_streaming (test_pb2_grpc.TestServiceStub stub)

def	_special_status_message (test_pb2_grpc.TestServiceStub stub)

def	_status_code_and_message (test_pb2_grpc.TestServiceStub stub)

def	_timeout_on_sleeping_server (test_pb2_grpc.TestServiceStub stub)

def	_unimplemented_method (test_pb2_grpc.TestServiceStub stub)

def	_unimplemented_service (test_pb2_grpc.UnimplementedServiceStub stub)

None	_validate_payload_type_and_length (Union[messages_pb2.SimpleResponse, messages_pb2.StreamingOutputCallResponse] response, Any expected_type, int expected_length)

None	_validate_status_code_and_details (aio.Call call, grpc.StatusCode expected_code, str expected_details)

None	test_interoperability (TestCase case, test_pb2_grpc.TestServiceStub stub, Optional[argparse.Namespace] args=None)

Variables
string	_INITIAL_METADATA_KEY = "x-grpc-test-echo-initial"

dictionary	_TEST_CASE_IMPLEMENTATION_MAPPING

string	_TRAILING_METADATA_KEY = "x-grpc-test-echo-trailing-bin"

Function Documentation

◆ _cancel_after_begin()

def tests_aio.interop.methods._cancel_after_begin ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 177 of file aio/interop/methods.py.

◆ _cancel_after_first_response()

def tests_aio.interop.methods._cancel_after_first_response ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 187 of file aio/interop/methods.py.

◆ _client_streaming()

None tests_aio.interop.methods._client_streaming ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 104 of file aio/interop/methods.py.

◆ _compute_engine_creds()

def tests_aio.interop.methods._compute_engine_creds	(	test_pb2_grpc.TestServiceStub	stub,
		argparse.Namespace	args
	)

private

Definition at line 333 of file aio/interop/methods.py.

◆ _custom_metadata()

def tests_aio.interop.methods._custom_metadata ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 293 of file aio/interop/methods.py.

◆ _empty_stream()

def tests_aio.interop.methods._empty_stream ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 246 of file aio/interop/methods.py.

◆ _empty_unary()

None tests_aio.interop.methods._empty_unary ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 93 of file aio/interop/methods.py.

◆ _expect_status_code()

None tests_aio.interop.methods._expect_status_code	(	aio.Call	call,
		grpc.StatusCode	expected_code
	)

private

Definition at line 43 of file aio/interop/methods.py.

◆ _expect_status_details()

None tests_aio.interop.methods._expect_status_details	(	aio.Call	call,
		str	expected_details
	)

private

Definition at line 51 of file aio/interop/methods.py.

◆ _jwt_token_creds()

def tests_aio.interop.methods._jwt_token_creds ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 355 of file aio/interop/methods.py.

◆ _large_unary()

None tests_aio.interop.methods._large_unary ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 100 of file aio/interop/methods.py.

◆ _large_unary_common_behavior()

messages_pb2.SimpleResponse tests_aio.interop.methods._large_unary_common_behavior	(	test_pb2_grpc.TestServiceStub	stub,
		bool	fill_username,
		bool	fill_oauth_scope,
		Optional[grpc.CallCredentials]	call_credentials
	)

private

Definition at line 77 of file aio/interop/methods.py.

◆ _oauth2_auth_token()

def tests_aio.interop.methods._oauth2_auth_token	(	test_pb2_grpc.TestServiceStub	stub,
		argparse.Namespace	args
	)

private

Definition at line 341 of file aio/interop/methods.py.

◆ _per_rpc_creds()

def tests_aio.interop.methods._per_rpc_creds	(	test_pb2_grpc.TestServiceStub	stub,
		argparse.Namespace	args
	)

private

Definition at line 364 of file aio/interop/methods.py.

◆ _ping_pong()

None tests_aio.interop.methods._ping_pong ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 146 of file aio/interop/methods.py.

◆ _server_streaming()

None tests_aio.interop.methods._server_streaming ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 123 of file aio/interop/methods.py.

◆ _special_status_message()

def tests_aio.interop.methods._special_status_message ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 381 of file aio/interop/methods.py.

◆ _status_code_and_message()

def tests_aio.interop.methods._status_code_and_message ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 252 of file aio/interop/methods.py.

◆ _timeout_on_sleeping_server()

def tests_aio.interop.methods._timeout_on_sleeping_server ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 224 of file aio/interop/methods.py.

◆ _unimplemented_method()

def tests_aio.interop.methods._unimplemented_method ( test_pb2_grpc.TestServiceStub stub )

private

Definition at line 283 of file aio/interop/methods.py.

◆ _unimplemented_service()

def tests_aio.interop.methods._unimplemented_service ( test_pb2_grpc.UnimplementedServiceStub stub )

private

Definition at line 288 of file aio/interop/methods.py.

◆ _validate_payload_type_and_length()

None tests_aio.interop.methods._validate_payload_type_and_length	(	Union[ messages_pb2.SimpleResponse, messages_pb2.StreamingOutputCallResponse]	response,
		Any	expected_type,
		int	expected_length
	)

private

Definition at line 65 of file aio/interop/methods.py.

◆ _validate_status_code_and_details()

None tests_aio.interop.methods._validate_status_code_and_details	(	aio.Call	call,
		grpc.StatusCode	expected_code,
		str	expected_details
	)

private

Definition at line 58 of file aio/interop/methods.py.

◆ test_interoperability()

None tests_aio.interop.methods.test_interoperability	(	TestCase	case,
		test_pb2_grpc.TestServiceStub	stub,
		Optional[argparse.Namespace]	args = `None`
	)

Definition at line 441 of file aio/interop/methods.py.

Variable Documentation

◆ _INITIAL_METADATA_KEY

string tests_aio.interop.methods._INITIAL_METADATA_KEY = "x-grpc-test-echo-initial"

private

Definition at line 39 of file aio/interop/methods.py.

◆ _TEST_CASE_IMPLEMENTATION_MAPPING

dictionary tests_aio.interop.methods._TEST_CASE_IMPLEMENTATION_MAPPING

private

Initial value:

 =  {
     TestCase.EMPTY_UNARY: _empty_unary,
     TestCase.LARGE_UNARY: _large_unary,
     TestCase.SERVER_STREAMING: _server_streaming,
     TestCase.CLIENT_STREAMING: _client_streaming,
     TestCase.PING_PONG: _ping_pong,
     TestCase.CANCEL_AFTER_BEGIN: _cancel_after_begin,
     TestCase.CANCEL_AFTER_FIRST_RESPONSE: _cancel_after_first_response,
     TestCase.TIMEOUT_ON_SLEEPING_SERVER: _timeout_on_sleeping_server,
     TestCase.EMPTY_STREAM: _empty_stream,
     TestCase.STATUS_CODE_AND_MESSAGE: _status_code_and_message,
     TestCase.UNIMPLEMENTED_METHOD: _unimplemented_method,
     TestCase.UNIMPLEMENTED_SERVICE: _unimplemented_service,
     TestCase.CUSTOM_METADATA: _custom_metadata,
     TestCase.COMPUTE_ENGINE_CREDS: _compute_engine_creds,
     TestCase.OAUTH2_AUTH_TOKEN: _oauth2_auth_token,
     TestCase.JWT_TOKEN_CREDS: _jwt_token_creds,
     TestCase.PER_RPC_CREDS: _per_rpc_creds,
     TestCase.SPECIAL_STATUS_MESSAGE: _special_status_message,
 }

Definition at line 419 of file aio/interop/methods.py.

◆ _TRAILING_METADATA_KEY

string tests_aio.interop.methods._TRAILING_METADATA_KEY = "x-grpc-test-echo-trailing-bin"

private

Definition at line 40 of file aio/interop/methods.py.

Classes

Functions

Variables

Function Documentation

◆ _cancel_after_begin()

◆ _cancel_after_first_response()

◆ _client_streaming()

◆ _compute_engine_creds()

◆ _custom_metadata()

◆ _empty_stream()

◆ _empty_unary()

◆ _expect_status_code()

◆ _expect_status_details()

◆ _jwt_token_creds()

◆ _large_unary()

◆ _large_unary_common_behavior()

◆ _oauth2_auth_token()

◆ _per_rpc_creds()

◆ _ping_pong()

◆ _server_streaming()

◆ _special_status_message()

◆ _status_code_and_message()

◆ _timeout_on_sleeping_server()

◆ _unimplemented_method()

◆ _unimplemented_service()

◆ _validate_payload_type_and_length()

◆ _validate_status_code_and_details()

◆ test_interoperability()

Variable Documentation

◆ _INITIAL_METADATA_KEY

◆ _TEST_CASE_IMPLEMENTATION_MAPPING

◆ _TRAILING_METADATA_KEY