postgres/typesense
1
0
Fork 0
mirror of https://github.com/typesense/typesense.git synced 2025-05-18 04:32:38 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Remove replication updates API.

Browse Source
This commit is contained in:
kishorenc 2020-03-30 20:37:09 +05:30
parent 30ec332e89
commit dd290884e5
3 changed files with 0 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
include/core_api.h
View File

@ -28,8 +28,6 @@ bool get_fetch_document(http_req & req, http_res & res);
bool del_remove_document(http_req & req, http_res & res);
bool get_replication_updates(http_req &req, http_res &res);
bool collection_export_handler(http_req* req, http_res* res, void* data);
bool async_write_request(void *data);

40
src/core_api.cpp
View File

@ -568,46 +568,6 @@ bool del_remove_document(http_req & req, http_res & res) {
return true;
}
bool get_replication_updates(http_req & req, http_res & res) {
// Could be heavy - spawn a new thread so we don't block the main thread
std::thread response_thread([&]() {
if(!StringUtils::is_uint64_t(req.params["seq_number"])) {
res.send_400("The value of the parameter `seq_number` must be an unsigned integer.");
return false;
}
const uint64_t MAX_UPDATES_TO_SEND = 10000;
uint64_t seq_number = std::stoull(req.params["seq_number"]);
CollectionManager & collectionManager = CollectionManager::get_instance();
Store* store = collectionManager.get_store();
Option<std::vector<std::string>*> updates_op = store->get_updates_since(seq_number, MAX_UPDATES_TO_SEND);
if(!updates_op.ok()) {
res.send(updates_op.code(), updates_op.error());
server->send_message(SEND_RESPONSE_MSG, new request_response{&req, &res});
return false;
}
nlohmann::json json_response;
json_response["updates"] = nlohmann::json::array();
std::vector<std::string> *updates = updates_op.get();
for(const std::string & update: *updates) {
json_response["updates"].push_back(StringUtils::base64_encode(update));
}
uint64_t latest_seq_num = store->get_latest_seq_number();
json_response["latest_seq_num"] = latest_seq_num;
res.send_200(json_response.dump());
server->send_message(SEND_RESPONSE_MSG, new request_response{&req, &res});
delete updates;
});
response_thread.detach();
return true;
}
bool async_write_request(void *data) {
//LOG(INFO) << "async_write_request called";
AsyncIndexArg* index_arg = static_cast<AsyncIndexArg*>(data);

6
src/main/typesense_server.cpp
View File

@ -22,9 +22,6 @@ void master_server_routes() {
// meta
server->get("/debug", get_debug);
server->get("/health", get_health);
// replication
server->get("/replication/updates", get_replication_updates, true);
}
void replica_server_routes() {
@ -40,9 +37,6 @@ void replica_server_routes() {
// meta
server->get("/debug", get_debug);
server->get("/health", get_health);
// replication
server->get("/replication/updates", get_replication_updates, true);
}
int main(int argc, char **argv) {