Cluster.h

#pragma once
 
#include <xrpld/overlay/ClusterNode.h>
 
#include <xrpl/basics/chrono.h>
#include <xrpl/beast/utility/Journal.h>
#include <xrpl/config/BasicConfig.h>
#include <xrpl/protocol/PublicKey.h>
 
#include <cstddef>
#include <cstdint>
#include <functional>
#include <mutex>
#include <optional>
#include <set>
#include <string>
#include <type_traits>
 
namespace xrpl {
 
class Cluster
{
private:
    struct Comparator
    {
        explicit Comparator() = default;
 
        // NOLINTNEXTLINE(readability-identifier-naming) -- std heterogeneous-lookup concept name
        using is_transparent = std::true_type;
 
        bool
        operator()(ClusterNode const& lhs, ClusterNode const& rhs) const
        {
            return lhs.identity() < rhs.identity();
        }
 
        bool
        operator()(ClusterNode const& lhs, PublicKey const& rhs) const
        {
            return lhs.identity() < rhs;
        }
 
        bool
        operator()(PublicKey const& lhs, ClusterNode const& rhs) const
        {
            return lhs < rhs.identity();
        }
    };
 
    std::set<ClusterNode, Comparator> nodes_;
    std::mutex mutable mutex_;
    beast::Journal mutable j_;
 
public:
    Cluster(beast::Journal j);

    std::optional<std::string>
    member(PublicKey const& node) const;

    bool
    isMember(PublicKey const& node) const;

    std::size_t
    size() const;

    bool
    update(
        PublicKey const& identity,
        std::string name,
        std::uint32_t loadFee = 0,
        NetClock::time_point reportTime = NetClock::time_point{});

    void
    forEach(std::function<void(ClusterNode const&)> func) const;

    bool
    load(Section const& nodes);
};
 
}  // namespace xrpl