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>
38 class CallbackUnaryCallImpl;
43 template <
class W,
class R>
47 template <
class W,
class R>
48 class ClientCallbackReaderWriterFactory;
50 class ClientCallbackReaderFactory;
52 class ClientCallbackWriterFactory;
53 class ClientCallbackUnaryFactory;
58 class ChannelInterface;
60 namespace experimental {
61 class DelegatingChannel;
66 class CallOpSetInterface;
68 class InterceptedChannel;
69 template <
class InputMessage,
class OutputMessage>
70 class BlockingUnaryCallImpl;
87 NotifyOnStateChangeImpl(last_observed, deadline_tp.
raw_time(), cq, tag);
95 return WaitForStateChangeImpl(last_observed, deadline_tp.
raw_time());
113 template <
class W,
class R>
119 template <
class W,
class R>
123 template <
class W,
class R>
124 friend class ::grpc_impl::internal::ClientCallbackReaderWriterFactory;
126 friend class ::grpc_impl::internal::ClientCallbackReaderFactory;
128 friend class ::grpc_impl::internal::ClientCallbackWriterFactory;
129 friend class ::grpc_impl::internal::ClientCallbackUnaryFactory;
130 template <
class InputMessage,
class OutputMessage>
131 friend class ::grpc::internal::BlockingUnaryCallImpl;
132 template <
class InputMessage,
class OutputMessage>
133 friend class ::grpc_impl::internal::CallbackUnaryCallImpl;
134 friend class ::grpc::internal::RpcMethod;
135 friend class ::grpc::experimental::DelegatingChannel;
136 friend class ::grpc::internal::InterceptedChannel;
142 virtual void* RegisterMethod(
const char* method) = 0;
Codegen interface for grpc::Channel.
Definition: channel_interface.h:74
void NotifyOnStateChange(grpc_connectivity_state last_observed, T deadline, ::grpc_impl::CompletionQueue *cq, void *tag)
Return the tag on cq when the channel state is changed or deadline expires.
Definition: channel_interface.h:84
bool WaitForConnected(T deadline)
Wait for this channel to be connected.
Definition: channel_interface.h:100
virtual ~ChannelInterface()
Definition: channel_interface.h:76
virtual grpc_connectivity_state GetState(bool try_to_connect)=0
Get the current channel state.
bool WaitForStateChange(grpc_connectivity_state last_observed, T deadline)
Blocking wait for channel state change or deadline expiration.
Definition: channel_interface.h:93
If you are trying to use CompletionQueue::AsyncNext with a time class that isn't either gpr_timespec ...
Definition: time.h:40
gpr_timespec raw_time()
Definition: time.h:43
Straightforward wrapping of the C call object.
Definition: call.h:38
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:34
Descriptor of an RPC method.
Definition: rpc_method.h:29
A ClientContext allows the person implementing a service client to:
Definition: client_context_impl.h:184
A thin wrapper around grpc_completion_queue (see src/core/lib/surface/completion_queue....
Definition: completion_queue_impl.h:100
grpc_connectivity_state
Connectivity state of a channel.
Definition: connectivity_state.h:27
@ GRPC_CHANNEL_READY
channel is ready for work
Definition: connectivity_state.h:33
::grpc_impl::internal::ClientAsyncResponseReaderFactory< R > ClientAsyncResponseReaderFactory
Definition: async_unary_call.h:40
::grpc_impl::internal::ClientAsyncReaderFactory< R > ClientAsyncReaderFactory
Definition: async_stream.h:81
::grpc_impl::internal::ClientAsyncReaderWriterFactory< W, R > ClientAsyncReaderWriterFactory
Definition: async_stream.h:89
::grpc_impl::internal::ClientAsyncWriterFactory< W > ClientAsyncWriterFactory
Definition: async_stream.h:85
An Alarm posts the user-provided tag to its associated completion queue or invokes the user-provided ...
Definition: alarm_impl.h:33
This header provides an object that reads bytes directly from a grpc::ByteBuffer, via the ZeroCopyInp...
Definition: alarm.h:24
::grpc_impl::ClientContext ClientContext
Definition: client_context.h:26
::grpc_impl::ClientReader< R > ClientReader
Definition: sync_stream.h:56
::grpc_impl::ClientWriter< W > ClientWriter
Definition: sync_stream.h:62
::grpc_impl::CompletionQueue CompletionQueue
Definition: completion_queue.h:26
::grpc_impl::ClientReaderWriter< W, R > ClientReaderWriter
Definition: sync_stream.h:69
Analogous to struct timespec.
Definition: gpr_types.h:47