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