Classes
class	_ChannelCallState

class	_ChannelConnectivityState

class	_InactiveRpcError

class	_InitialMetadataFlags

class	_MultiThreadedRendezvous

class	_Rendezvous

class	_RPCState

class	_SingleThreadedRendezvous

class	_SingleThreadedUnaryStreamMultiCallable

class	_StreamStreamMultiCallable

class	_StreamUnaryMultiCallable

class	_UnaryStreamMultiCallable

class	_UnaryUnaryMultiCallable

class	Channel

Functions
def	_abort (state, code, details)

def	_augment_options (base_options, compression)

def	_channel_managed_call_management (state)

def	_consume_request_iterator (request_iterator, state, call, request_serializer, event_handler)

def	_deadline (timeout)

def	_deliver (state, initial_connectivity, initial_callbacks)

def	_deliveries (state)

def	_determine_deadline (user_deadline)

def	_end_unary_response_blocking (state, call, with_call, deadline)

def	_event_handler (state, response_deserializer)

def	_handle_event (event, state, response_deserializer)

def	_poll_connectivity (state, channel, initial_try_to_connect)

def	_rpc_state_string (class_name, rpc_state)

def	_run_channel_spin_thread (state)

def	_separate_channel_options (options)

def	_spawn_delivery (state, callbacks)

def	_start_unary_request (request, timeout, request_serializer)

def	_stream_unary_invocation_operationses (metadata, initial_metadata_flags)

def	_stream_unary_invocation_operationses_and_tags (metadata, initial_metadata_flags)

def	_subscribe (state, callback, try_to_connect)

def	_unknown_code_details (unknown_cygrpc_code, details)

def	_unsubscribe (state, callback)

Variables
tuple	_CHANNEL_SUBSCRIPTION_CALLBACK_ERROR_LOG_MESSAGE

	_DEFAULT_SINGLE_THREADED_UNARY_STREAM

int	_EMPTY_FLAGS = 0

	_LOGGER = logging.getLogger(__name__)

tuple	_NON_OK_RENDEZVOUS_REPR_FORMAT

tuple	_OK_RENDEZVOUS_REPR_FORMAT

tuple	_STREAM_STREAM_INITIAL_DUE

tuple	_STREAM_UNARY_INITIAL_DUE

tuple	_UNARY_STREAM_INITIAL_DUE

tuple	_UNARY_UNARY_INITIAL_DUE

string	_USER_AGENT = 'grpc-python/{}'.format(_grpcio_metadata.__version__)

Function Documentation

◆ _abort()

def grpc._channel._abort	(	state,
		code,
		details
	)

private

Definition at line 126 of file grpc/_channel.py.

◆ _augment_options()

def grpc._channel._augment_options	(	base_options,
		compression
	)

private

Definition at line 1442 of file grpc/_channel.py.

◆ _channel_managed_call_management()

def grpc._channel._channel_managed_call_management ( state )

private

Definition at line 1273 of file grpc/_channel.py.

◆ _consume_request_iterator()

def grpc._channel._consume_request_iterator	(	request_iterator,
		state,
		call,
		request_serializer,
		event_handler
	)

private

Consume a request iterator supplied by the user.

Definition at line 191 of file grpc/_channel.py.

◆ _deadline()

def grpc._channel._deadline ( timeout )

private

Definition at line 84 of file grpc/_channel.py.

◆ _deliver()

def grpc._channel._deliver	(	state,
		initial_connectivity,
		initial_callbacks
	)

private

Definition at line 1343 of file grpc/_channel.py.

◆ _deliveries()

def grpc._channel._deliveries ( state )

private

Definition at line 1333 of file grpc/_channel.py.

◆ _determine_deadline()

def grpc._channel._determine_deadline ( user_deadline )

private

Definition at line 873 of file grpc/_channel.py.

◆ _end_unary_response_blocking()

def grpc._channel._end_unary_response_blocking	(	state,
		call,
		with_call,
		deadline
	)

private

Definition at line 841 of file grpc/_channel.py.

◆ _event_handler()

def grpc._channel._event_handler	(	state,
		response_deserializer
	)

private

Definition at line 170 of file grpc/_channel.py.

◆ _handle_event()

def grpc._channel._handle_event	(	event,
		state,
		response_deserializer
	)

private

Definition at line 135 of file grpc/_channel.py.

◆ _poll_connectivity()

def grpc._channel._poll_connectivity	(	state,
		channel,
		initial_try_to_connect
	)

private

Definition at line 1376 of file grpc/_channel.py.

◆ _rpc_state_string()

def grpc._channel._rpc_state_string	(	class_name,
		rpc_state
	)

private

Calculates error string for RPC.

Definition at line 269 of file grpc/_channel.py.

◆ _run_channel_spin_thread()

def grpc._channel._run_channel_spin_thread ( state )

private

Definition at line 1253 of file grpc/_channel.py.

◆ _separate_channel_options()

def grpc._channel._separate_channel_options ( options )

private

Separates core channel options from Python channel options.

Definition at line 1450 of file grpc/_channel.py.

◆ _spawn_delivery()

def grpc._channel._spawn_delivery	(	state,
		callbacks
	)

private

Definition at line 1363 of file grpc/_channel.py.

◆ _start_unary_request()

def grpc._channel._start_unary_request	(	request,
		timeout,
		request_serializer
	)

private

Definition at line 829 of file grpc/_channel.py.

◆ _stream_unary_invocation_operationses()

def grpc._channel._stream_unary_invocation_operationses	(	metadata,
		initial_metadata_flags
	)

private

Definition at line 852 of file grpc/_channel.py.

◆ _stream_unary_invocation_operationses_and_tags()

def grpc._channel._stream_unary_invocation_operationses_and_tags	(	metadata,
		initial_metadata_flags
	)

private

Definition at line 864 of file grpc/_channel.py.

◆ _subscribe()

def grpc._channel._subscribe	(	state,
		callback,
		try_to_connect
	)

private

Definition at line 1413 of file grpc/_channel.py.

◆ _unknown_code_details()

def grpc._channel._unknown_code_details	(	unknown_cygrpc_code,
		details
	)

private

Definition at line 88 of file grpc/_channel.py.

◆ _unsubscribe()

def grpc._channel._unsubscribe	(	state,
		callback
	)

private

Definition at line 1433 of file grpc/_channel.py.

Variable Documentation

◆ _CHANNEL_SUBSCRIPTION_CALLBACK_ERROR_LOG_MESSAGE

tuple grpc._channel._CHANNEL_SUBSCRIPTION_CALLBACK_ERROR_LOG_MESSAGE

private

Initial value:

1 = (

2 'Exception calling channel subscription callback!')

Definition at line 69 of file grpc/_channel.py.

◆ _DEFAULT_SINGLE_THREADED_UNARY_STREAM

grpc._channel._DEFAULT_SINGLE_THREADED_UNARY_STREAM

private

Initial value:

1 = os.getenv(

2 "GRPC_SINGLE_THREADED_UNARY_STREAM") is not None

Definition at line 39 of file grpc/_channel.py.

◆ _EMPTY_FLAGS

int grpc._channel._EMPTY_FLAGS = 0

private

Definition at line 35 of file grpc/_channel.py.

◆ _LOGGER

grpc._channel._LOGGER = logging.getLogger(__name__)

private

Definition at line 31 of file grpc/_channel.py.

◆ _NON_OK_RENDEZVOUS_REPR_FORMAT

tuple grpc._channel._NON_OK_RENDEZVOUS_REPR_FORMAT

private

Initial value:

 =  ('<{} of RPC that terminated with:\n'
                                   '\tstatus = {}\n'
                                   '\tdetails = "{}"\n'
                                   '\tdebug_error_string = "{}"\n'
                                   '>')

Definition at line 77 of file grpc/_channel.py.

◆ _OK_RENDEZVOUS_REPR_FORMAT

tuple grpc._channel._OK_RENDEZVOUS_REPR_FORMAT

private

Initial value:

 =  ('<{} of RPC that terminated with:\n'
                               '\tstatus = {}\n'
                               '\tdetails = "{}"\n'
                               '>')

Definition at line 72 of file grpc/_channel.py.

◆ _STREAM_STREAM_INITIAL_DUE

tuple grpc._channel._STREAM_STREAM_INITIAL_DUE

private

Initial value:

 =  (
     cygrpc.OperationType.send_initial_metadata,
     cygrpc.OperationType.receive_initial_metadata,
     cygrpc.OperationType.receive_status_on_client,
 )

Definition at line 63 of file grpc/_channel.py.

◆ _STREAM_UNARY_INITIAL_DUE

tuple grpc._channel._STREAM_UNARY_INITIAL_DUE

private

Initial value:

 =  (
     cygrpc.OperationType.send_initial_metadata,
     cygrpc.OperationType.receive_initial_metadata,
     cygrpc.OperationType.receive_message,
     cygrpc.OperationType.receive_status_on_client,
 )

Definition at line 57 of file grpc/_channel.py.

◆ _UNARY_STREAM_INITIAL_DUE

tuple grpc._channel._UNARY_STREAM_INITIAL_DUE

private

Initial value:

 =  (
     cygrpc.OperationType.send_initial_metadata,
     cygrpc.OperationType.send_message,
     cygrpc.OperationType.send_close_from_client,
     cygrpc.OperationType.receive_initial_metadata,
     cygrpc.OperationType.receive_status_on_client,
 )

Definition at line 50 of file grpc/_channel.py.

◆ _UNARY_UNARY_INITIAL_DUE

tuple grpc._channel._UNARY_UNARY_INITIAL_DUE

private

Initial value:

 =  (
     cygrpc.OperationType.send_initial_metadata,
     cygrpc.OperationType.send_message,
     cygrpc.OperationType.send_close_from_client,
     cygrpc.OperationType.receive_initial_metadata,
     cygrpc.OperationType.receive_message,
     cygrpc.OperationType.receive_status_on_client,
 )

Definition at line 42 of file grpc/_channel.py.

◆ _USER_AGENT

string grpc._channel._USER_AGENT = 'grpc-python/{}'.format(_grpcio_metadata.__version__)

private

Definition at line 33 of file grpc/_channel.py.

Classes

Functions

Variables

Function Documentation

◆ _abort()

◆ _augment_options()

◆ _channel_managed_call_management()

◆ _consume_request_iterator()

◆ _deadline()

◆ _deliver()

◆ _deliveries()

◆ _determine_deadline()

◆ _end_unary_response_blocking()

◆ _event_handler()

◆ _handle_event()

◆ _poll_connectivity()

◆ _rpc_state_string()

◆ _run_channel_spin_thread()

◆ _separate_channel_options()

◆ _spawn_delivery()

◆ _start_unary_request()

◆ _stream_unary_invocation_operationses()

◆ _stream_unary_invocation_operationses_and_tags()

◆ _subscribe()

◆ _unknown_code_details()

◆ _unsubscribe()

Variable Documentation

◆ _CHANNEL_SUBSCRIPTION_CALLBACK_ERROR_LOG_MESSAGE

◆ _DEFAULT_SINGLE_THREADED_UNARY_STREAM

◆ _EMPTY_FLAGS

◆ _LOGGER

◆ _NON_OK_RENDEZVOUS_REPR_FORMAT

◆ _OK_RENDEZVOUS_REPR_FORMAT

◆ _STREAM_STREAM_INITIAL_DUE

◆ _STREAM_UNARY_INITIAL_DUE

◆ _UNARY_STREAM_INITIAL_DUE

◆ _UNARY_UNARY_INITIAL_DUE

◆ _USER_AGENT