Skip to content

Template Class TConsumerRPCBackend

Template Class TConsumerRPCBackend

  • Defined in File ConsumerRPCBackend.h

Inheritance Relationships

Base Types

template <class ServiceType, typename RequestType, typename ResponseType>
class TConsumerRPCBackend
: public TRPCBackend<ServiceType, RequestType, ResponseType>,
public IConsumerBackend<RequestType>

Source: Source/Schola/Protobuf/Public/ProtobufBackends/gRPC/ConsumerRPCBackend.h

Dependencies: TCallData, TConsumerRPCWorker, TRPCBackend


Public Functions

SymbolDetails
TConsumerRPCBackend
~TConsumerRPCBackend
PollPoll the Backend for a message from the client.
InitializePerform any setup that happens prior to establishing any external connection.
Start
EstablishPerform any setup that involves handshakes with the external communication (e.g.
ShutdownClose the external connection.
RestartReset the Communication backend.

TConsumerRPCBackend

inline TConsumerRPCBackend(gRPCBackend::AsyncRPCHandle TargetRPC,
std::shared_ptr<ServiceType> Service,
std::unique_ptr<ServerCompletionQueue> CQueue)
#DirectionNameTypeDescription
1TargetRPCgRPCBackend::AsyncRPCHandle
2Servicestd::shared_ptr< ServiceType >
3CQueuestd::unique_ptr< ServerCompletionQueue >

Attributes: inline

Source: Source/Schola/Protobuf/Public/ProtobufBackends/gRPC/ConsumerRPCBackend.h


~TConsumerRPCBackend

inline ~TConsumerRPCBackend()

Attributes: inline

Source: Source/Schola/Protobuf/Public/ProtobufBackends/gRPC/ConsumerRPCBackend.h

Poll

inline virtual TOptional<const RequestType *> Poll() override

Poll the Backend for a message from the client.

Returns:

An Empty optional if No messages have been received, a fulfilled one otherwise

Attributes: inline, virtual

Source: Source/Schola/Protobuf/Public/ProtobufBackends/gRPC/ConsumerRPCBackend.h

Initialize

inline virtual void Initialize()

Perform any setup that happens prior to establishing any external connection.

this could include opening a socket and waiting for a connection.

Attributes: inline, virtual

Source: Source/Schola/Protobuf/Public/ProtobufBackends/gRPC/ConsumerRPCBackend.h

Start

inline virtual void Start() override

Attributes: inline, virtual

Source: Source/Schola/Protobuf/Public/ProtobufBackends/gRPC/ConsumerRPCBackend.h

Establish

inline virtual void Establish()

Perform any setup that involves handshakes with the external communication (e.g.

setting up serialization). Use after Initialize.

Attributes: inline, virtual

Source: Source/Schola/Protobuf/Public/ProtobufBackends/gRPC/ConsumerRPCBackend.h

Shutdown

inline virtual void Shutdown() override

Close the external connection.

Attributes: inline, virtual

Source: Source/Schola/Protobuf/Public/ProtobufBackends/gRPC/ConsumerRPCBackend.h

Restart

inline virtual void Restart()

Reset the Communication backend.

Attributes: inline, virtual

Source: Source/Schola/Protobuf/Public/ProtobufBackends/gRPC/ConsumerRPCBackend.h