|
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: