![]() |
Gossip 1.1
|
#include <GossipPeerNode.h>
Public Member Functions | |
AsyncClientCall () | |
Constructor of AsyncClientCall. Construct all objects needed in async rpc. | |
~AsyncClientCall () | |
Destructor of AsyncClientCall. Release all objects needed in async rpc. | |
void | start () |
Start async rpc. | |
void | retry (GossipPeerNode *node) |
Retry async rpc. | |
Public Attributes | |
Input * | input_ |
The input of rpc. | |
Output * | reply_ |
The output of rpc. | |
grpc::ClientContext | context_ |
The context of rpc. | |
grpc::Status | status_ |
The status of rpc. | |
std::unique_ptr< grpc::ClientAsyncResponseReader< Output > > | reader_ |
rpc result reader | |
std::function< void()> | cb_ = {} |
function to handle rpc output | |
std::function< void(GossipPeerNode *)> | retry_ = {} |
retry function | |
Class AsyncClientCall is used to handle async rpc request. All objects used in async rpc is managed by this class.
Input | Input type of async rpc |
Output | Output type of async rpc |