Template Class TConsumerRPCBackend
Template Class TConsumerRPCBackend
- Defined in File ConsumerRPCBackend.h
Inheritance Relationships
Base Types
-
public TRPCBackend< ServiceType, RequestType, ResponseType >(Template Class TRPCBackend) -
public IConsumerBackend< RequestType >(Template Class IConsumerBackend)
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
| Symbol | Details |
|---|---|
TConsumerRPCBackend | — |
~TConsumerRPCBackend | — |
Poll | Poll the Backend for a message from the client. |
Initialize | Perform any setup that happens prior to establishing any external connection. |
Start | — |
Establish | Perform any setup that involves handshakes with the external communication (e.g. |
Shutdown | Close the external connection. |
Restart | Reset the Communication backend. |
TConsumerRPCBackend
inline TConsumerRPCBackend(gRPCBackend::AsyncRPCHandle TargetRPC, std::shared_ptr<ServiceType> Service, std::unique_ptr<ServerCompletionQueue> CQueue)| # | Direction | Name | Type | Description |
|---|---|---|---|---|
| 1 | — | TargetRPC | gRPCBackend::AsyncRPCHandle | — |
| 2 | — | Service | std::shared_ptr< ServiceType > | — |
| 3 | — | CQueue | std::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() overridePoll 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() overrideAttributes: 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() overrideClose 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