Loading...
Searching...
No Matches
resdb::MockReplicaCommunicator Class Reference

#include <mock_replica_communicator.h>

Inheritance diagram for resdb::MockReplicaCommunicator:
resdb::ReplicaCommunicator resdb::ReplicaCommunicator

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)
 

Detailed Description

Definition at line 28 of file mock_replica_communicator.h.

Constructor & Destructor Documentation

◆ MockReplicaCommunicator() [1/2]

resdb::MockReplicaCommunicator::MockReplicaCommunicator ( )
inline

Definition at line 30 of file mock_replica_communicator.h.

◆ MockReplicaCommunicator() [2/2]

resdb::MockReplicaCommunicator::MockReplicaCommunicator ( const std::vector< ReplicaInfo > &  replicas)
inline

Definition at line 31 of file mock_replica_communicator.h.

Member Function Documentation

◆ MOCK_METHOD() [1/6]

resdb::MockReplicaCommunicator::MOCK_METHOD ( int  ,
SendBatchMessage  ,
(const std::vector< std::unique_ptr< Request > > &, const ReplicaInfo &)  ,
(override)   
)

◆ MOCK_METHOD() [2/6]

resdb::MockReplicaCommunicator::MOCK_METHOD ( int  ,
SendHeartBeat  ,
(const Request &)  ,
(override)   
)

◆ MOCK_METHOD() [3/6]

resdb::MockReplicaCommunicator::MOCK_METHOD ( int  ,
SendMessage  ,
(const google::protobuf::Message &)  ,
(override)   
)

◆ MOCK_METHOD() [4/6]

resdb::MockReplicaCommunicator::MOCK_METHOD ( int  ,
SendMessage  ,
(const google::protobuf::Message &, const ReplicaInfo &)  ,
(override)   
)

◆ MOCK_METHOD() [5/6]

resdb::MockReplicaCommunicator::MOCK_METHOD ( void  ,
BroadCast  ,
(const google::protobuf::Message &)  ,
(override)   
)

◆ MOCK_METHOD() [6/6]

resdb::MockReplicaCommunicator::MOCK_METHOD ( void  ,
SendMessage  ,
(const google::protobuf::Message &, int64_t)  ,
(override)   
)