#include <mock_replica_communicator.h>
Public Member Functions | |
| MockReplicaCommunicator () | |
| MockReplicaCommunicator (const std::vector< ReplicaInfo > &replicas) | |
| MOCK_METHOD (int, SendHeartBeat,(const Request &),(override)) | |
| MOCK_METHOD (int, SendMessage,(const google::protobuf::Message &),(override)) | |
| MOCK_METHOD (void, BroadCast,(const google::protobuf::Message &),(override)) | |
| MOCK_METHOD (void, SendMessage,(const google::protobuf::Message &, int64_t),(override)) | |
| MOCK_METHOD (int, SendMessage,(const google::protobuf::Message &, const ReplicaInfo &),(override)) | |
| MOCK_METHOD (int, SendBatchMessage,(const std::vector< std::unique_ptr< Request > > &, const ReplicaInfo &),(override)) | |
Public Member Functions inherited from resdb::ReplicaCommunicator | |
| ReplicaCommunicator (const std::vector< ReplicaInfo > &replicas, SignatureVerifier *verifier=nullptr, bool is_use_long_conn=false, int epoll_num=1, int tcp_batch=100) | |
| virtual | ~ReplicaCommunicator () |
| virtual int | SendHeartBeat (const Request &hb_info) |
| virtual int | SendMessage (const google::protobuf::Message &message) |
| virtual int | SendMessage (const google::protobuf::Message &message, const ReplicaInfo &replica_info) |
| virtual void | BroadCast (const google::protobuf::Message &message) |
| virtual void | SendMessage (const google::protobuf::Message &message, int64_t node_id) |
| virtual int | SendBatchMessage (const std::vector< std::unique_ptr< Request > > &messages, const ReplicaInfo &replica_info) |
| void | UpdateClientReplicas (const std::vector< ReplicaInfo > &replicas) |
| std::vector< ReplicaInfo > | GetClientReplicas () |
Additional Inherited Members | |
Protected Member Functions inherited from resdb::ReplicaCommunicator | |
| virtual std::unique_ptr< NetChannel > | GetClient (const std::string &ip, int port) |
| virtual AsyncReplicaClient * | GetClientFromPool (const std::string &ip, int port) |
| void | StartBroadcastInBackGround () |
| int | SendMessageInternal (const google::protobuf::Message &message, const std::vector< ReplicaInfo > &replicas) |
| int | SendMessageFromPool (const google::protobuf::Message &message, const std::vector< ReplicaInfo > &replicas) |
| bool | IsRunning () const |
| bool | IsInPool (const ReplicaInfo &replica_info) |
Definition at line 28 of file mock_replica_communicator.h.
|
inline |
Definition at line 30 of file mock_replica_communicator.h.
|
inline |
Definition at line 31 of file mock_replica_communicator.h.
| resdb::MockReplicaCommunicator::MOCK_METHOD | ( | int | , |
| SendBatchMessage | , | ||
| (const std::vector< std::unique_ptr< Request > > &, const ReplicaInfo &) | , | ||
| (override) | |||
| ) |
| resdb::MockReplicaCommunicator::MOCK_METHOD | ( | int | , |
| SendHeartBeat | , | ||
| (const Request &) | , | ||
| (override) | |||
| ) |
| resdb::MockReplicaCommunicator::MOCK_METHOD | ( | int | , |
| SendMessage | , | ||
| (const google::protobuf::Message &) | , | ||
| (override) | |||
| ) |
| resdb::MockReplicaCommunicator::MOCK_METHOD | ( | int | , |
| SendMessage | , | ||
| (const google::protobuf::Message &, const ReplicaInfo &) | , | ||
| (override) | |||
| ) |
| resdb::MockReplicaCommunicator::MOCK_METHOD | ( | void | , |
| BroadCast | , | ||
| (const google::protobuf::Message &) | , | ||
| (override) | |||
| ) |
| resdb::MockReplicaCommunicator::MOCK_METHOD | ( | void | , |
| SendMessage | , | ||
| (const google::protobuf::Message &, int64_t) | , | ||
| (override) | |||
| ) |