#include <userver/ugrpc/server/rpc.hpp>
Controls a single request -> single response RPC.
The RPC is cancelled on destruction unless Finish has been called.
Inheritance diagram for ugrpc::server::UnaryCall< Response >:
Collaboration diagram for ugrpc::server::UnaryCall< Response >:Public Member Functions | |
| void | Finish (const Response &response) |
| Complete the RPC successfully. | |
| void | FinishWithError (const grpc::Status &status) override |
| Complete the RPC with an error. | |
| UnaryCall (impl::CallParams &&call_params, impl::RawResponseWriter< Response > &stream) | |
| For internal use only. | |
| UnaryCall (UnaryCall &&)=delete | |
| UnaryCall & | operator= (UnaryCall &&)=delete |
| bool | IsFinished () const override |
Public Member Functions inherited from ugrpc::server::CallAnyBase | |
| CallAnyBase (impl::CallParams &¶ms) | |
| grpc::ServerContext & | GetContext () |
| std::string_view | GetCallName () const |
| Name of the call. Consists of service and method names. | |
| tracing::Span & | GetSpan () |
| utils::AnyStorage< StorageContext > & | GetStorageContext () |
| Returns call context for storing per-call custom data. | |
Additional Inherited Members | |
Protected Member Functions inherited from ugrpc::server::CallAnyBase | |
| ugrpc::impl::RpcStatisticsScope & | Statistics () |
| logging::LoggerRef | AccessTskvLogger () |
| void | LogFinish (grpc::Status status) const |
| ugrpc::server::UnaryCall< Response >::UnaryCall | ( | impl::CallParams && | call_params, |
| impl::RawResponseWriter< Response > & | stream ) |
| ugrpc::server::UnaryCall< Response >::~UnaryCall | ( | ) |
| void ugrpc::server::UnaryCall< Response >::Finish | ( | const Response & | response | ) |
Complete the RPC successfully.
Finish must not be called multiple times for the same RPC.
| response | the single Response to send to the client |
| ugrpc::server::RpcError | on an RPC error |
|
overridevirtual |
Complete the RPC with an error.
Finish must not be called multiple times for the same RPC.
| status | error details |
| ugrpc::server::RpcError | on an RPC error |
Implements ugrpc::server::CallAnyBase.
|
overridevirtual |
Implements ugrpc::server::CallAnyBase.