replicated_shard_client.hpp

Go to the documentation of this file.

// Copyright (c) 2022 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_PARSEC_RUNTIME_LOCKING_SHARD_REPLICATED_SHARD_CLIENT_H_
#define OPENCBDC_TX_SRC_PARSEC_RUNTIME_LOCKING_SHARD_REPLICATED_SHARD_CLIENT_H_
 
#include "messages.hpp"
#include "replicated_shard_interface.hpp"
#include "util/raft/node.hpp"
 
namespace cbdc::parsec::runtime_locking_shard {
    class replicated_shard_client final : public replicated_shard_interface {
      public:
        explicit replicated_shard_client(
            std::shared_ptr<raft::node> raft_node);
 
        auto prepare(ticket_number_type ticket_number,
                     broker_id_type broker_id,
                     state_type state_update,
                     callback_type result_callback) -> bool override;
 
        auto commit(ticket_number_type ticket_number,
                    callback_type result_callback) -> bool override;
 
        auto finish(ticket_number_type ticket_number,
                    callback_type result_callback) -> bool override;
 
        [[nodiscard]] auto
        get_tickets(get_tickets_callback_type result_callback) const
            -> bool override;
 
      private:
        std::shared_ptr<raft::node> m_raft;
 
        auto replicate_request(
            const rpc::replicated_request& req,
            const std::function<void(std::optional<rpc::replicated_response>)>&
                result_callback) const -> bool;
    };
}
 
#endif