state_manager.hpp

Go to the documentation of this file.

// Copyright (c) 2021 MIT Digital Currency Initiative,
//                    Federal Reserve Bank of Boston
// Distributed under the MIT software license, see the accompanying
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
 
#ifndef OPENCBDC_TX_SRC_RAFT_STATE_MANAGER_H_
#define OPENCBDC_TX_SRC_RAFT_STATE_MANAGER_H_
 
#include "log_store.hpp"
#include "util/network/socket.hpp"
 
#include <libnuraft/nuraft.hxx>
 
namespace cbdc::raft {
    class state_manager : public nuraft::state_mgr {
      public:
        state_manager(int32_t srv_id,
                      std::string log_dir,
                      std::string config_file,
                      std::string state_file,
                      std::vector<network::endpoint_t> raft_endpoints);
        ~state_manager() override = default;
 
        state_manager(const state_manager& other) = delete;
        auto operator=(const state_manager& other) -> state_manager& = delete;
 
        state_manager(state_manager&& other) noexcept;
        auto operator=(state_manager&& other) noexcept -> state_manager&;
 
        auto load_config() -> nuraft::ptr<nuraft::cluster_config> override;
 
        void save_config(const nuraft::cluster_config& config) override;
 
        void save_state(const nuraft::srv_state& state) override;
 
        auto read_state() -> nuraft::ptr<nuraft::srv_state> override;
 
        auto load_log_store() -> nuraft::ptr<nuraft::log_store> override;
 
        auto server_id() -> int32_t override;
 
        void system_exit(int exit_code) override;
 
      private:
        int32_t m_id;
        std::string m_config_file;
        std::string m_state_file;
        std::string m_log_dir;
        std::vector<network::endpoint_t> m_raft_endpoints;
    };
}
 
#endif // OPENCBDC_TX_SRC_RAFT_STATE_MANAGER_H_