GRPC C++
1.30.0
|
Actual implementation of bi-directional streaming. More...
Data Structures | |
class | AsyncReaderInterface |
An interface that yields a sequence of messages of type R. More... | |
class | AsyncWriterInterface |
An interface that can be fed a sequence of messages of type W. More... | |
class | BidiStreamingHandler |
class | CallbackBidiHandler |
class | CallbackClientStreamingHandler |
class | CallbackServerStreamingHandler |
class | CallbackUnaryCallImpl |
class | CallbackUnaryHandler |
class | ClientAsyncReaderFactory |
class | ClientAsyncReaderWriterFactory |
class | ClientAsyncResponseReaderFactory |
class | ClientAsyncStreamingInterface |
Common interface for all client side asynchronous streaming. More... | |
class | ClientAsyncWriterFactory |
class | ClientCallbackReaderFactory |
class | ClientCallbackReaderImpl |
class | ClientCallbackReaderWriterFactory |
class | ClientCallbackReaderWriterImpl |
class | ClientCallbackUnaryFactory |
class | ClientCallbackUnaryImpl |
class | ClientCallbackWriterFactory |
class | ClientCallbackWriterImpl |
class | ClientReaderFactory |
class | ClientReaderWriterFactory |
class | ClientStreamingHandler |
A wrapper class of an application provided client streaming handler. More... | |
class | ClientStreamingInterface |
Common interface for all synchronous client side streaming. More... | |
class | ClientWriterFactory |
class | DefaultMessageHolder |
class | ErrorMethodHandler |
General method handler class for errors that prevent real method use e.g., handle unknown method by returning UNIMPLEMENTED error. More... | |
class | FinishOnlyReactor |
class | ReaderInterface |
An interface that yields a sequence of messages of type R. More... | |
class | RpcMethodHandler |
A wrapper class of an application provided rpc method handler. More... | |
class | ServerCallbackCall |
The base class of ServerCallbackUnary etc. More... | |
class | ServerReactor |
class | ServerReaderWriterBody |
class | ServerStreamingHandler |
A wrapper class of an application provided server streaming handler. More... | |
class | ServerStreamingInterface |
Common interface for all synchronous server side streaming. More... | |
class | SplitServerStreamingHandler |
class | StreamedUnaryHandler |
class | TemplatedBidiStreamingHandler |
A wrapper class of an application provided bidi-streaming handler. More... | |
class | WriterInterface |
An interface that can be fed a sequence of messages of type W. More... | |
Typedefs | |
typedef ErrorMethodHandler<::grpc::StatusCode::UNIMPLEMENTED > | UnknownMethodHandler |
typedef ErrorMethodHandler<::grpc::StatusCode::RESOURCE_EXHAUSTED > | ResourceExhaustedHandler |
using | UnimplementedUnaryReactor = FinishOnlyReactor< ServerUnaryReactor > |
template<class Request > | |
using | UnimplementedReadReactor = FinishOnlyReactor< ServerReadReactor< Request > > |
template<class Response > | |
using | UnimplementedWriteReactor = FinishOnlyReactor< ServerWriteReactor< Response > > |
template<class Request , class Response > | |
using | UnimplementedBidiReactor = FinishOnlyReactor< ServerBidiReactor< Request, Response > > |
Functions | |
template<class InputMessage , class OutputMessage > | |
void | CallbackUnaryCall (::grpc::ChannelInterface *channel, const ::grpc::internal::RpcMethod &method, ::grpc_impl::ClientContext *context, const InputMessage *request, OutputMessage *result, std::function< void(::grpc::Status)> on_completion) |
Perform a callback-based unary call TODO(vjpai): Combine as much as possible with the blocking unary call code. More... | |
template<class Callable > | |
::grpc::Status | CatchingFunctionHandler (Callable &&handler) |
Actual implementation of bi-directional streaming.
typedef ErrorMethodHandler<::grpc::StatusCode::RESOURCE_EXHAUSTED> grpc_impl::internal::ResourceExhaustedHandler |
using grpc_impl::internal::UnimplementedBidiReactor = typedef FinishOnlyReactor<ServerBidiReactor<Request, Response> > |
using grpc_impl::internal::UnimplementedReadReactor = typedef FinishOnlyReactor<ServerReadReactor<Request> > |
using grpc_impl::internal::UnimplementedUnaryReactor = typedef FinishOnlyReactor<ServerUnaryReactor> |
using grpc_impl::internal::UnimplementedWriteReactor = typedef FinishOnlyReactor<ServerWriteReactor<Response> > |
typedef ErrorMethodHandler<::grpc::StatusCode::UNIMPLEMENTED> grpc_impl::internal::UnknownMethodHandler |
void grpc_impl::internal::CallbackUnaryCall | ( | ::grpc::ChannelInterface * | channel, |
const ::grpc::internal::RpcMethod & | method, | ||
::grpc_impl::ClientContext * | context, | ||
const InputMessage * | request, | ||
OutputMessage * | result, | ||
std::function< void(::grpc::Status)> | on_completion | ||
) |
Perform a callback-based unary call TODO(vjpai): Combine as much as possible with the blocking unary call code.
::grpc::Status grpc_impl::internal::CatchingFunctionHandler | ( | Callable && | handler | ) |