parsec/runtime_locking_shard/client.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_PARSEC_RUNTIME_LOCKING_SHARD_CLIENT_H_
#define OPENCBDC_TX_SRC_PARSEC_RUNTIME_LOCKING_SHARD_CLIENT_H_
 
#include "interface.hpp"
#include "messages.hpp"
#include "util/rpc/tcp_client.hpp"
 
namespace cbdc::parsec::runtime_locking_shard::rpc {
    class client : public interface {
      public:
        explicit client(std::vector<network::endpoint_t> endpoints);
 
        client() = delete;
        ~client() override = default;
        client(const client&) = delete;
        auto operator=(const client&) -> client& = delete;
        client(client&&) = delete;
        auto operator=(client&&) -> client& = delete;
 
        auto init() -> bool;
 
        auto try_lock(ticket_number_type ticket_number,
                      broker_id_type broker_id,
                      key_type key,
                      lock_type locktype,
                      bool first_lock,
                      try_lock_callback_type result_callback) -> bool override;
 
        auto prepare(ticket_number_type ticket_number,
                     broker_id_type broker_id,
                     state_update_type state_update,
                     prepare_callback_type result_callback) -> bool override;
 
        auto commit(ticket_number_type ticket_number,
                    commit_callback_type result_callback) -> bool override;
 
        auto rollback(ticket_number_type ticket_number,
                      rollback_callback_type result_callback) -> bool override;
 
        auto finish(ticket_number_type ticket_number,
                    finish_callback_type result_callback) -> bool override;
 
        auto get_tickets(broker_id_type broker_id,
                         get_tickets_callback_type result_callback)
            -> bool override;
 
      private:
        std::unique_ptr<cbdc::rpc::tcp_client<request, response>> m_client;
    };
}
 
#endif