Loading...
Searching...
No Matches
resdb::ReplicaCommunicator Member List

This is the complete list of members for resdb::ReplicaCommunicator, including all inherited members.

BroadCast(const google::protobuf::Message &message)resdb::ReplicaCommunicatorvirtual
GetClient(const std::string &ip, int port)resdb::ReplicaCommunicatorprotectedvirtual
GetClientFromPool(const std::string &ip, int port)resdb::ReplicaCommunicatorprotectedvirtual
GetClientReplicas()resdb::ReplicaCommunicator
IsInPool(const ReplicaInfo &replica_info)resdb::ReplicaCommunicatorprotected
IsRunning() constresdb::ReplicaCommunicatorprotected
ReplicaCommunicator(const std::vector< ReplicaInfo > &replicas, SignatureVerifier *verifier=nullptr, bool is_use_long_conn=false, int epoll_num=1, int tcp_batch=100)resdb::ReplicaCommunicator
SendBatchMessage(const std::vector< std::unique_ptr< Request > > &messages, const ReplicaInfo &replica_info)resdb::ReplicaCommunicatorvirtual
SendHeartBeat(const Request &hb_info)resdb::ReplicaCommunicatorvirtual
SendMessage(const google::protobuf::Message &message)resdb::ReplicaCommunicatorvirtual
SendMessage(const google::protobuf::Message &message, const ReplicaInfo &replica_info)resdb::ReplicaCommunicatorvirtual
SendMessage(const google::protobuf::Message &message, int64_t node_id)resdb::ReplicaCommunicatorvirtual
SendMessageFromPool(const google::protobuf::Message &message, const std::vector< ReplicaInfo > &replicas)resdb::ReplicaCommunicatorprotected
SendMessageInternal(const google::protobuf::Message &message, const std::vector< ReplicaInfo > &replicas)resdb::ReplicaCommunicatorprotected
StartBroadcastInBackGround()resdb::ReplicaCommunicatorprotected
UpdateClientReplicas(const std::vector< ReplicaInfo > &replicas)resdb::ReplicaCommunicator
~ReplicaCommunicator()resdb::ReplicaCommunicatorvirtual