#include <userver/ugrpc/server/rpc.hpp>

Detailed Description

template<typename Request, typename Response>
class ugrpc::server::BidirectionalStream< Request, Response >

Controls a request stream -> response stream RPC.

This class allows the following concurrent calls:

GetContext
Read;
one of (Write, Finish, FinishWithError, WriteAndFinish).

The RPC is cancelled on destruction unless the stream has been finished.

If any method throws, further methods must not be called on the same stream, except for GetContext.

Definition at line 207 of file rpc.hpp.

Inheritance diagram for ugrpc::server::BidirectionalStream< Request, Response >:

Public Member Functions
bool	Read (Request &request) override
	Await and read the next incoming message.

void	Write (Response &response) override
	Write the next outgoing message.

void	Write (Response &&response) override
	Write the next outgoing message.

void	Finish ()
	Complete the RPC successfully.

void	FinishWithError (const grpc::Status &status) override
	Complete the RPC with an error.

void	WriteAndFinish (Response &response)
	Equivalent to `Write + Finish`

void	WriteAndFinish (Response &&response)
	Equivalent to `Write + Finish`

	BidirectionalStream (impl::CallParams &&call_params, impl::RawReaderWriter< Request, Response > &stream)
	For internal use only.

	BidirectionalStream (const BidirectionalStream &)=delete

	BidirectionalStream (BidirectionalStream &&)=delete

bool	IsFinished () const override
	Useful for generic error reporting via FinishWithError.

grpc::ServerContext &	GetContext ()

std::string_view	GetCallName () const
	Name of the RPC in the format `full.path.ServiceName/MethodName`

std::string_view	GetServiceName () const
	Get name of gRPC service.

std::string_view	GetMethodName () const
	Get name of called gRPC method.

tracing::Span &	GetSpan ()
	Get the span of the current RPC. Span's lifetime covers the `Handle` call of the outermost middleware.

CallKind	GetCallKind () const
	Get RPCs kind of method.

utils::AnyStorage< StorageContext > &	GetStorageContext ()
	Returns call context for storing per-call custom data.

void	SetMetricsCallName (std::string_view call_name)
	Set a custom call name for metric labels.

Protected Member Functions
ugrpc::impl::RpcStatisticsScope &	GetStatistics ()

logging::LoggerRef	AccessTskvLogger ()

void	LogFinish (grpc::Status status) const

void	ApplyRequestHook (google::protobuf::Message *request)

void	ApplyResponseHook (google::protobuf::Message *response)

Constructor & Destructor Documentation

◆ BidirectionalStream()

template<typename Request , typename Response >

ugrpc::server::BidirectionalStream< Request, Response >::BidirectionalStream	(	impl::CallParams &&	call_params,
		impl::RawReaderWriter< Request, Response > &	stream )

For internal use only.

Definition at line 472 of file rpc.hpp.

◆ ~BidirectionalStream()

template<typename Request , typename Response >

ugrpc::server::BidirectionalStream< Request, Response >::~BidirectionalStream ( )

override

Definition at line 480 of file rpc.hpp.

Member Function Documentation

◆ AccessTskvLogger()

logging::LoggerRef ugrpc::server::CallAnyBase::AccessTskvLogger ( )

inlineprotectedinherited

Definition at line 105 of file call.hpp.

◆ Finish()

template<typename Request , typename Response >

void ugrpc::server::BidirectionalStream< Request, Response >::Finish ( )

Complete the RPC successfully.

Finish must not be called multiple times.

Exceptions

ugrpc::server::RpcError on an RPC error

Definition at line 525 of file rpc.hpp.

◆ FinishWithError()

template<typename Request , typename Response >

void ugrpc::server::BidirectionalStream< Request, Response >::FinishWithError ( const grpc::Status & status )

overridevirtual

Complete the RPC with an error.

Finish must not be called multiple times.

Parameters

status error details

Exceptions

ugrpc::server::RpcError on an RPC error

Implements ugrpc::server::CallAnyBase.

Definition at line 537 of file rpc.hpp.

◆ GetCallKind()

CallKind ugrpc::server::CallAnyBase::GetCallKind ( ) const

inlineinherited

Get RPCs kind of method.

Definition at line 58 of file call.hpp.

◆ GetCallName()

std::string_view ugrpc::server::CallAnyBase::GetCallName ( ) const

inlineinherited

Name of the RPC in the format full.path.ServiceName/MethodName

Definition at line 45 of file call.hpp.

◆ GetContext()

grpc::ServerContext & ugrpc::server::CallAnyBase::GetContext ( )

inlineinherited

Returns: the ServerContext used for this RPC

Note: Initial server metadata is not currently supported; Trailing metadata, if any, must be set before the Finish call

Examples: samples/grpc_middleware_service/src/middlewares/server/middleware.cpp.

Definition at line 42 of file call.hpp.

◆ GetSpan()

tracing::Span & ugrpc::server::CallAnyBase::GetSpan ( )

inlineinherited

Get the span of the current RPC. Span's lifetime covers the Handle call of the outermost middleware.

Definition at line 55 of file call.hpp.

◆ GetStatistics()

ugrpc::impl::RpcStatisticsScope & ugrpc::server::CallAnyBase::GetStatistics ( )

inlineprotectedinherited

Definition at line 103 of file call.hpp.

◆ GetStorageContext()

utils::AnyStorage< StorageContext > & ugrpc::server::CallAnyBase::GetStorageContext ( )

inlineinherited

Returns call context for storing per-call custom data.

The context can be used to pass data from server middleware to client handler or from one middleware to another one.

Example usage:

In authentication middleware:

if (password_is_correct) {
  // Username is authenticated, set it in per-call storage context
  ctx.GetCall().GetStorageContext().Emplace(kAuthUsername, username);
}

In client handler:

const auto& username = rpc.GetStorageContext().Get(kAuthUsername);

auto msg = fmt::format("Hello, {}!", username);

Definition at line 82 of file call.hpp.

◆ IsFinished()

template<typename Request , typename Response >

bool ugrpc::server::BidirectionalStream< Request, Response >::IsFinished ( ) const

overridevirtual

Useful for generic error reporting via FinishWithError.

Implements ugrpc::server::CallAnyBase.

Definition at line 575 of file rpc.hpp.

◆ Read()

template<typename Request , typename Response >

bool ugrpc::server::BidirectionalStream< Request, Response >::Read ( Request & request )

overridevirtual

Await and read the next incoming message.

Parameters

request where to put the request on success

Returns: true on success, false on end-of-input

Exceptions

ugrpc::server::RpcError on an RPC error

Implements ugrpc::server::Reader< Request >.

Definition at line 488 of file rpc.hpp.

◆ Write() [1/2]

template<typename Request , typename Response >

void ugrpc::server::BidirectionalStream< Request, Response >::Write ( Response && response )

overridevirtual

Write the next outgoing message.

Parameters

response the next message to write

Exceptions

ugrpc::server::RpcError on an RPC error

Implements ugrpc::server::Writer< Response >.

Definition at line 502 of file rpc.hpp.

◆ Write() [2/2]

template<typename Request , typename Response >

void ugrpc::server::BidirectionalStream< Request, Response >::Write ( Response & response )

overridevirtual

Write the next outgoing message.

Parameters

response the next message to write

Exceptions

ugrpc::server::RpcError on an RPC error

Implements ugrpc::server::Writer< Response >.

Definition at line 507 of file rpc.hpp.

◆ WriteAndFinish() [1/2]

template<typename Request , typename Response >

void ugrpc::server::BidirectionalStream< Request, Response >::WriteAndFinish ( Response && response )

Equivalent to Write + Finish

This call saves one round-trip, compared to separate Write and Finish.

Finish must not be called multiple times.

Parameters

response the final response message

Exceptions

ugrpc::server::RpcError on an RPC error

Definition at line 548 of file rpc.hpp.

◆ WriteAndFinish() [2/2]

template<typename Request , typename Response >

void ugrpc::server::BidirectionalStream< Request, Response >::WriteAndFinish ( Response & response )

Equivalent to Write + Finish

This call saves one round-trip, compared to separate Write and Finish.

Finish must not be called multiple times.

Parameters

response the final response message

Exceptions

ugrpc::server::RpcError on an RPC error

Definition at line 553 of file rpc.hpp.

The documentation for this class was generated from the following file:

userver/ugrpc/server/rpc.hpp

Detailed Description

Public Member Functions

Protected Member Functions

Constructor & Destructor Documentation

◆ BidirectionalStream()

◆ ~BidirectionalStream()

Member Function Documentation

◆ AccessTskvLogger()

◆ Finish()

◆ FinishWithError()

◆ GetCallKind()

◆ GetCallName()

◆ GetContext()

◆ GetSpan()

◆ GetStatistics()

◆ GetStorageContext()

Example usage:

◆ IsFinished()

◆ Read()

◆ Write() [1/2]

◆ Write() [2/2]

◆ WriteAndFinish() [1/2]

◆ WriteAndFinish() [2/2]