Implement Raft protocol to replicate KV pairs

.vscode/launch.json

@@ -4,6 +4,33 @@
     // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
     "version": "0.2.0",
     "configurations": [
+        {
+            "name": "rr - RaftMain",
+            "type": "cppdbg",
+            "request": "launch",
+            "program": "${workspaceFolder}/build/RaftMain",
+            "miDebuggerServerAddress": "localhost:50505",
+            "stopAtEntry": false,
+            "cwd": "${workspaceFolder}",
+            "environment": [],
+            "externalConsole": true,
+            "linux": {
+                "MIMode": "gdb",
+                "setupCommands": [
+                    {
+                        "description": "Setup to resolve symbols",
+                        "text": "set sysroot /",
+                        "ignoreFailures": false
+                    }
+                ]
+            },
+            "osx": {
+                "MIMode": "gdb"
+            },
+            "windows": {
+                "MIMode": "gdb"
+            }
+        },
         {
             "name": "Debug - LSMTreeTest",
             "type": "cppdbg",
@@ -84,7 +111,7 @@
             "args": [
                 "-c",
                 "./assets/tkvpp_config.json"
-            ], // Arguments to pass to the program
+            ],
             "stopAtEntry": false, // Set to true to stop at the program's entry point
             "cwd": "${workspaceFolder}", // Current working directory
             "environment": [],

CMakeLists.txt

@@ -7,8 +7,8 @@ set(CMAKE_CXX_STANDARD 23)
 set(CMAKE_CXX_STANDARD_REQUIRED On)
 set(CMAKE_CXX_EXTENSIONS Off)
 
-set(CMAKE_C_FLAGS "${CMAKE_C_FLAGS} -Wall -Wextra -pedantic-errors")
-set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -Wall -Wextra -pedantic-errors")
+set(CMAKE_C_FLAGS "${CMAKE_C_FLAGS} -Wall -Wextra -Wthread-safety -pedantic-errors")
+set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -Wall -Wextra -Wthread-safety -pedantic-errors")
 
 set(CMAKE_ARCHIVE_OUTPUT_DIRECTORY "${PROJECT_BINARY_DIR}")
 set(CMAKE_LIBRARY_OUTPUT_DIRECTORY "${PROJECT_BINARY_DIR}")

examples/CMakeLists.txt

@@ -3,3 +3,4 @@ project(zkv)
 
 add_subdirectory(absl)
 add_subdirectory(embedded)
+add_subdirectory(raft)

examples/raft/CMakeLists.txt

@@ -0,0 +1,6 @@
+cmake_minimum_required(VERSION 3.25)
+project(zkv)
+
+add_executable(RaftMain "main.cpp" "raft.cpp")
+set_target_properties(RaftMain PROPERTIES CXX_STANDARD 23)
+target_link_libraries(RaftMain PRIVATE DB RaftProtoObjects)

examples/raft/main.cpp

@@ -0,0 +1,70 @@
+#include <random>
+
+#include "raft.h"
+
+#include <grpcpp/server.h>
+
+#include <cxxopts.hpp>
+
+#include <spdlog/spdlog.h>
+
+auto generateRandomTimeout() -> int
+{
+    const int minTimeout{150};
+    const int maxTimeout{300};
+
+    std::random_device              randomDevice;
+    std::mt19937                    gen(randomDevice());
+    std::uniform_int_distribution<> dist(minTimeout, maxTimeout);
+
+    return dist(gen);
+}
+
+int main(int argc, char *argv[])
+{
+    cxxopts::Options options("raft");
+    options.add_options()("id", "id of the node", cxxopts::value<ID>())(
+        "nodes", "ip addresses of replicas in a correct order", cxxopts::value<std::vector<IP>>());
+
+    auto parsedOptions = options.parse(argc, argv);
+    if ((parsedOptions.count("help") != 0U) || (parsedOptions.count("id") == 0U) ||
+        (parsedOptions.count("nodes") == 0U))
+    {
+        spdlog::info("{}", options.help());
+        return EXIT_SUCCESS;
+    }
+
+    auto nodeId = parsedOptions["id"].as<ID>();
+    auto nodeIps = parsedOptions["nodes"].as<std::vector<IP>>();
+    for (auto ip : nodeIps)
+    {
+        spdlog::info(ip);
+    }
+
+    spdlog::info("nodeIps.size()={}", nodeIps.size());
+
+    if (nodeId == 0)
+    {
+        spdlog::error("ID of the node should be positve integer");
+        return EXIT_FAILURE;
+    }
+
+    if (nodeIps.empty())
+    {
+        spdlog::error("List of node IPs can't be empty");
+        return EXIT_FAILURE;
+    }
+
+    ConsensusModule cm(nodeId, nodeIps);
+    if (!cm.init())
+    {
+        spdlog::error("Failed to initialize the state machine");
+        return EXIT_FAILURE;
+    }
+
+    cm.start();
+
+    cm.stop();
+
+    return EXIT_SUCCESS;
+}