Inheritance diagram for grpc_testing.Channel:
Public Member Functions | |
| def | take_stream_stream (self, method_descriptor) |
| def | take_stream_unary (self, method_descriptor) |
| def | take_unary_stream (self, method_descriptor) |
| def | take_unary_unary (self, method_descriptor) |
 Public Member Functions inherited from grpc::Channel | |
| def | __enter__ (self) |
| def | __exit__ (self, exc_type, exc_val, exc_tb) |
| def | close (self) |
| std::string | GetLoadBalancingPolicyName () const |
| Returns the LB policy name, or the empty string if not yet available. More... | |
| std::string | GetServiceConfigJSON () const |
| grpc_connectivity_state | GetState (bool try_to_connect) override |
| def | stream_stream (self, method, request_serializer=None, response_deserializer=None) |
| def | stream_unary (self, method, request_serializer=None, response_deserializer=None) |
| def | subscribe (self, callback, try_to_connect=False) |
| def | unary_stream (self, method, request_serializer=None, response_deserializer=None) |
| def | unary_unary (self, method, request_serializer=None, response_deserializer=None) |
| def | unsubscribe (self, callback) |
| ~Channel () override | |
| Public Member Functions inherited from grpc::ChannelInterface | |
| template<typename T > | |
| void | NotifyOnStateChange (grpc_connectivity_state last_observed, T deadline, grpc::CompletionQueue *cq, void *tag) |
| template<typename T > | |
| bool | WaitForConnected (T deadline) |
| Wait for this channel to be connected. More... | |
| template<typename T > | |
| bool | WaitForStateChange (grpc_connectivity_state last_observed, T deadline) |
| virtual | ~ChannelInterface () |
| Public Member Functions inherited from grpc::internal::CallHook | |
| virtual | ~CallHook () |
Detailed Description
A grpc.Channel double with which to test a system that invokes RPCs.
Definition at line 215 of file src/python/grpcio_testing/grpc_testing/__init__.py.
Member Function Documentation
◆ take_stream_stream()
| def grpc_testing.Channel.take_stream_stream | ( | self, | |
| method_descriptor | |||
| ) |
Draws an RPC currently being made by the system under test.
If the given descriptor does not identify any RPC currently being made
by the system under test, this method blocks until the system under
test invokes such an RPC.
Args:
method_descriptor: A descriptor.MethodDescriptor describing a
stream-stream RPC method.
Returns:
A (invocation_metadata, stream_stream_channel_rpc) tuple of the RPC's
invocation metadata and a StreamStreamChannelRpc with which to
"play server" for the RPC.
Reimplemented in grpc_testing._channel._channel.TestingChannel.
Definition at line 276 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ take_stream_unary()
| def grpc_testing.Channel.take_stream_unary | ( | self, | |
| method_descriptor | |||
| ) |
Draws an RPC currently being made by the system under test.
If the given descriptor does not identify any RPC currently being made
by the system under test, this method blocks until the system under
test invokes such an RPC.
Args:
method_descriptor: A descriptor.MethodDescriptor describing a
stream-unary RPC method.
Returns:
A (invocation_metadata, stream_unary_channel_rpc) tuple of the RPC's
invocation metadata and a StreamUnaryChannelRpc with which to "play
server" for the RPC.
Reimplemented in grpc_testing._channel._channel.TestingChannel.
Definition at line 257 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ take_unary_stream()
| def grpc_testing.Channel.take_unary_stream | ( | self, | |
| method_descriptor | |||
| ) |
Draws an RPC currently being made by the system under test.
If the given descriptor does not identify any RPC currently being made
by the system under test, this method blocks until the system under
test invokes such an RPC.
Args:
method_descriptor: A descriptor.MethodDescriptor describing a
unary-stream RPC method.
Returns:
A (invocation_metadata, request, unary_stream_channel_rpc) tuple of
the RPC's invocation metadata, its request, and a
UnaryStreamChannelRpc with which to "play server" for the RPC.
Reimplemented in grpc_testing._channel._channel.TestingChannel.
Definition at line 238 of file src/python/grpcio_testing/grpc_testing/__init__.py.
◆ take_unary_unary()
| def grpc_testing.Channel.take_unary_unary | ( | self, | |
| method_descriptor | |||
| ) |
Draws an RPC currently being made by the system under test.
If the given descriptor does not identify any RPC currently being made
by the system under test, this method blocks until the system under
test invokes such an RPC.
Args:
method_descriptor: A descriptor.MethodDescriptor describing a
unary-unary RPC method.
Returns:
A (invocation_metadata, request, unary_unary_channel_rpc) tuple of
the RPC's invocation metadata, its request, and a
UnaryUnaryChannelRpc with which to "play server" for the RPC.
Reimplemented in grpc_testing._channel._channel.TestingChannel.
Definition at line 219 of file src/python/grpcio_testing/grpc_testing/__init__.py.
The documentation for this class was generated from the following file: