![]() |
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 |