parsec/agent/interface.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_AGENT_INTERFACE_H_
#define OPENCBDC_TX_SRC_PARSEC_AGENT_INTERFACE_H_
 
#include "parsec/broker/interface.hpp"
 
namespace cbdc::parsec::agent {
    using parameter_type = buffer;
    using return_type = broker::state_update_type;
 
    class interface {
      public:
        virtual ~interface() = default;
 
        interface(const interface&) = delete;
        auto operator=(const interface&) -> interface& = delete;
        interface(interface&&) = delete;
        auto operator=(interface&&) -> interface& = delete;
 
        enum class error_code : uint8_t {
            broker_unreachable,
            ticket_number_assignment,
            function_retrieval,
            function_execution,
            commit_error,
            finish_error,
            rollback_error,
            retry
        };
 
        using exec_return_type = std::variant<return_type, error_code>;
        using exec_callback_type = std::function<void(exec_return_type)>;
 
        interface(runtime_locking_shard::key_type function,
                  parameter_type param,
                  exec_callback_type result_callback);
 
        virtual auto exec() -> bool = 0;
 
        [[nodiscard]] auto get_function() const
            -> runtime_locking_shard::key_type;
 
        [[nodiscard]] auto get_param() const -> parameter_type;
 
        [[nodiscard]] auto get_result_callback() const -> exec_callback_type;
 
      private:
        runtime_locking_shard::key_type m_function;
        parameter_type m_param;
        exec_callback_type m_result_callback;
    };
}
 
#endif