Cluster.h

#ifndef XRPL_OVERLAY_CLUSTER_H_INCLUDED
#define XRPL_OVERLAY_CLUSTER_H_INCLUDED
 
#include <xrpld/overlay/ClusterNode.h>
 
#include <xrpl/basics/BasicConfig.h>
#include <xrpl/basics/chrono.h>
#include <xrpl/beast/utility/Journal.h>
#include <xrpl/protocol/PublicKey.h>
 
#include <functional>
#include <mutex>
#include <set>
 
namespace ripple {
 
class Cluster
{
private:
    struct Comparator
    {
        explicit Comparator() = default;
 
        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;
 
    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
    for_each(std::function<void(ClusterNode const&)> func) const;
 
    bool
    load(Section const& nodes);
};
 
}  // namespace ripple
 
#endif