|
| def | _abort (state, call, code, details) |
| |
| def | _abortion_code (state, code) |
| |
| def | _add_generic_handlers (state, generic_handlers) |
| |
| def | _add_insecure_port (state, address) |
| |
| def | _add_secure_port (state, address, server_credentials) |
| |
| def | _application_code (code) |
| |
| def | _augment_options (base_options, compression) |
| |
| def | _begin_shutdown_once (state) |
| |
| def | _call_behavior (rpc_event, state, behavior, argument, request_deserializer, send_response_callback=None) |
| |
| def | _completion_code (state) |
| |
| def | _details (state) |
| |
| def | _find_method_handler (rpc_event, generic_handlers, interceptor_pipeline) |
| |
| def | _get_initial_metadata (state, metadata) |
| |
| def | _get_initial_metadata_operation (state, metadata) |
| |
| def | _get_send_message_op_flags_from_state (state) |
| |
| def | _handle_call (rpc_event, generic_handlers, interceptor_pipeline, thread_pool, concurrency_exceeded) |
| |
| def | _handle_stream_stream (rpc_event, state, method_handler, default_thread_pool) |
| |
| def | _handle_stream_unary (rpc_event, state, method_handler, default_thread_pool) |
| |
| def | _handle_unary_stream (rpc_event, state, method_handler, default_thread_pool) |
| |
| def | _handle_unary_unary (rpc_event, state, method_handler, default_thread_pool) |
| |
| def | _handle_with_method_handler (rpc_event, method_handler, thread_pool) |
| |
| def | _is_rpc_state_active (state) |
| |
| def | _on_call_completed (state) |
| |
| def | _possibly_finish_call (state, token) |
| |
| def | _process_event_and_continue (state, event) |
| |
| def | _raise_rpc_error (state) |
| |
| def | _receive_close_on_server (state) |
| |
| def | _receive_message (state, call, request_deserializer) |
| |
| def | _reject_rpc (rpc_event, status, details) |
| |
| def | _request_call (state) |
| |
| def | _reset_per_message_state (state) |
| |
| def | _select_thread_pool_for_behavior (behavior, default_thread_pool) |
| |
| def | _send_initial_metadata (state) |
| |
| def | _send_message (state, token) |
| |
| def | _send_message_callback_to_blocking_iterator_adapter (rpc_event, state, send_response_callback, response_iterator) |
| |
| def | _send_response (rpc_event, state, serialized_response) |
| |
| def | _send_status_from_server (state, token) |
| |
| def | _serialize_response (rpc_event, state, response, response_serializer) |
| |
| def | _serialized_request (request_event) |
| |
| def | _serve (state) |
| |
| def | _start (state) |
| |
| def | _status (rpc_event, state, serialized_response) |
| |
| def | _stop (state, grace) |
| |
| def | _stop_serving (state) |
| |
| def | _stream_response_in_pool (rpc_event, state, behavior, argument_thunk, request_deserializer, response_serializer) |
| |
| def | _take_response_from_response_iterator (rpc_event, state, response_iterator) |
| |
| def | _unary_request (rpc_event, state, request_deserializer) |
| |
| def | _unary_response_in_pool (rpc_event, state, behavior, argument_thunk, request_deserializer, response_serializer) |
| |
| def | _validate_generic_rpc_handlers (generic_rpc_handlers) |
| |
| def | create_server (thread_pool, generic_rpc_handlers, interceptors, options, maximum_concurrent_rpcs, compression, xds) |
| |