|
| def | __init__ (self, handler, invocation_metadata) |
| |
| def | add_callback (self, callback) |
| |
| def | add_rpc_error (self, rpc_error) |
| |
| def | application_cancel (self) |
| |
| def | application_exception_abort (self, exception) |
| |
| def | extrinsic_abort (self) |
| |
| def | invocation_metadata (self) |
| |
| def | is_active (self) |
| |
| def | send_initial_metadata (self, initial_metadata) |
| |
| def | set_code (self, code) |
| |
| def | set_details (self, details) |
| |
| def | set_trailing_metadata (self, trailing_metadata) |
| |
| def | stream_response (self, response) |
| |
| def | stream_response_complete (self) |
| |
| def | unary_response_complete (self, response) |
| |
Definition at line 25 of file _rpc.py.
◆ __init__()
| def grpc_testing._server._rpc.Rpc.__init__ |
( |
|
self, |
|
|
|
handler, |
|
|
|
invocation_metadata |
|
) |
| |
◆ _abort()
| def grpc_testing._server._rpc.Rpc._abort |
( |
|
self, |
|
|
|
code, |
|
|
|
details |
|
) |
| |
|
private |
◆ _call_back()
| def grpc_testing._server._rpc.Rpc._call_back |
( |
|
self | ) |
|
|
private |
◆ _complete()
| def grpc_testing._server._rpc.Rpc._complete |
( |
|
self | ) |
|
|
private |
◆ _ensure_initial_metadata_sent()
| def grpc_testing._server._rpc.Rpc._ensure_initial_metadata_sent |
( |
|
self | ) |
|
|
private |
◆ _terminate()
| def grpc_testing._server._rpc.Rpc._terminate |
( |
|
self, |
|
|
|
trailing_metadata, |
|
|
|
code, |
|
|
|
details |
|
) |
| |
|
private |
◆ add_callback()
| def grpc_testing._server._rpc.Rpc.add_callback |
( |
|
self, |
|
|
|
callback |
|
) |
| |
◆ add_rpc_error()
| def grpc_testing._server._rpc.Rpc.add_rpc_error |
( |
|
self, |
|
|
|
rpc_error |
|
) |
| |
◆ application_cancel()
| def grpc_testing._server._rpc.Rpc.application_cancel |
( |
|
self | ) |
|
◆ application_exception_abort()
| def grpc_testing._server._rpc.Rpc.application_exception_abort |
( |
|
self, |
|
|
|
exception |
|
) |
| |
◆ extrinsic_abort()
| def grpc_testing._server._rpc.Rpc.extrinsic_abort |
( |
|
self | ) |
|
◆ invocation_metadata()
| def grpc_testing._server._rpc.Rpc.invocation_metadata |
( |
|
self | ) |
|
◆ is_active()
| def grpc_testing._server._rpc.Rpc.is_active |
( |
|
self | ) |
|
◆ send_initial_metadata()
| def grpc_testing._server._rpc.Rpc.send_initial_metadata |
( |
|
self, |
|
|
|
initial_metadata |
|
) |
| |
◆ set_code()
| def grpc_testing._server._rpc.Rpc.set_code |
( |
|
self, |
|
|
|
code |
|
) |
| |
◆ set_details()
| def grpc_testing._server._rpc.Rpc.set_details |
( |
|
self, |
|
|
|
details |
|
) |
| |
◆ set_trailing_metadata()
| def grpc_testing._server._rpc.Rpc.set_trailing_metadata |
( |
|
self, |
|
|
|
trailing_metadata |
|
) |
| |
◆ stream_response()
| def grpc_testing._server._rpc.Rpc.stream_response |
( |
|
self, |
|
|
|
response |
|
) |
| |
◆ stream_response_complete()
| def grpc_testing._server._rpc.Rpc.stream_response_complete |
( |
|
self | ) |
|
◆ unary_response_complete()
| def grpc_testing._server._rpc.Rpc.unary_response_complete |
( |
|
self, |
|
|
|
response |
|
) |
| |
◆ _active
| grpc_testing._server._rpc.Rpc._active |
|
private |
◆ _callbacks
| grpc_testing._server._rpc.Rpc._callbacks |
|
private |
◆ _condition
| grpc_testing._server._rpc.Rpc._condition |
|
private |
◆ _handler
| grpc_testing._server._rpc.Rpc._handler |
|
private |
◆ _initial_metadata_sent
| grpc_testing._server._rpc.Rpc._initial_metadata_sent |
|
private |
◆ _invocation_metadata
| grpc_testing._server._rpc.Rpc._invocation_metadata |
|
private |
◆ _pending_code
| grpc_testing._server._rpc.Rpc._pending_code |
|
private |
◆ _pending_details
| grpc_testing._server._rpc.Rpc._pending_details |
|
private |
◆ _pending_trailing_metadata
| grpc_testing._server._rpc.Rpc._pending_trailing_metadata |
|
private |
◆ _rpc_errors
| grpc_testing._server._rpc.Rpc._rpc_errors |
|
private |
The documentation for this class was generated from the following file: