|
@@ -31,7 +31,7 @@ public:
|
|
|
std::string address;
|
|
std::string address;
|
|
|
std::string nodeId;
|
|
std::string nodeId;
|
|
|
std::shared_ptr<grpc::Channel> channel;
|
|
std::shared_ptr<grpc::Channel> channel;
|
|
|
- std::unique_ptr<pb::StorageReplication::Stub> stub;
|
|
|
|
|
|
|
+ std::unique_ptr<pb::DatabaseReplication::Stub> stub;
|
|
|
std::atomic<bool> connected{false};
|
|
std::atomic<bool> connected{false};
|
|
|
uint64_t lastWatermark = 0;
|
|
uint64_t lastWatermark = 0;
|
|
|
std::vector<std::string> collections; // Collections on peer
|
|
std::vector<std::string> collections; // Collections on peer
|