Go to the documentation of this file.
19 #ifndef GRPCPP_IMPL_CODEGEN_CHANNEL_INTERFACE_H
20 #define GRPCPP_IMPL_CODEGEN_CHANNEL_INTERFACE_H
34 template <
class W,
class R>
37 template <
class InputMessage,
class OutputMessage>
43 template <
class W,
class R>
46 template <
class W,
class R>
59 namespace experimental {
60 class DelegatingChannel;
65 class CallOpSetInterface;
67 class InterceptedChannel;
68 template <
class InputMessage,
class OutputMessage>
86 NotifyOnStateChangeImpl(last_observed, deadline_tp.
raw_time(), cq, tag);
94 return WaitForStateChangeImpl(last_observed, deadline_tp.
raw_time());
112 template <
class W,
class R>
118 template <
class W,
class R>
121 template <
class W,
class R>
128 template <
class InputMessage,
class OutputMessage>
130 template <
class InputMessage,
class OutputMessage>
140 virtual void* RegisterMethod(
const char* method) = 0;
172 #endif // GRPCPP_IMPL_CODEGEN_CHANNEL_INTERFACE_H
Synchronous (blocking) client-side API for doing client-streaming RPCs, where the outgoing message st...
Definition: channel_interface.h:33
An Alarm posts the user-provided tag to its associated completion queue or invokes the user-provided ...
Definition: alarm.h:33
Definition: channel_interface.h:44
Definition: channel_interface.h:69
Straightforward wrapping of the C call object.
Definition: call.h:36
bool WaitForStateChange(grpc_connectivity_state last_observed, T deadline)
Blocking wait for channel state change or deadline expiration.
Definition: channel_interface.h:92
Definition: channel_interface.h:40
Synchronous (blocking) client-side API for doing server-streaming RPCs, where the stream of messages ...
Definition: channel_interface.h:31
Definition: channel_interface.h:51
A ClientContext allows the person implementing a service client to:
Definition: client_context.h:195
grpc_connectivity_state
Connectivity state of a channel.
Definition: connectivity_state.h:30
Definition: channel_interface.h:47
An abstract collection of call ops, used to generate the grpc_call_op structure to pass down to the l...
Definition: call_op_set_interface.h:36
Definition: channel_interface.h:38
bool WaitForConnected(T deadline)
Wait for this channel to be connected.
Definition: channel_interface.h:99
gpr_timespec raw_time()=delete
Definition: delegating_channel.h:31
Codegen interface for grpc::Channel.
Definition: channel_interface.h:73
Definition: async_unary_call.h:78
An InterceptedChannel is available to client Interceptors.
Definition: intercepted_channel.h:37
Definition: client_callback.h:1206
virtual ~ChannelInterface()
Definition: channel_interface.h:75
void NotifyOnStateChange(grpc_connectivity_state last_observed, T deadline, grpc::CompletionQueue *cq, void *tag)
Return the tag on cq when the channel state is changed or deadline expires.
Definition: channel_interface.h:83
Synchronous (blocking) client-side API for bi-directional streaming RPCs, where the outgoing message ...
Definition: channel_interface.h:35
virtual grpc_connectivity_state GetState(bool try_to_connect)=0
Get the current channel state.
A thin wrapper around grpc_completion_queue (see src/core/lib/surface/completion_queue....
Definition: completion_queue.h:104
Definition: channel_interface.h:49
Definition: channel_interface.h:42
Descriptor of an RPC method.
Definition: rpc_method.h:31
Analogous to struct timespec.
Definition: gpr_types.h:50
@ GRPC_CHANNEL_READY
channel is ready for work
Definition: connectivity_state.h:36
If you are trying to use CompletionQueue::AsyncNext with a time class that isn't either gpr_timespec ...
Definition: time.h:42