ResourceManager.h

#pragma once
 
#include <xrpl/beast/insight/Collector.h>
#include <xrpl/beast/net/IPEndpoint.h>
#include <xrpl/beast/utility/Journal.h>
#include <xrpl/beast/utility/PropertyStream.h>
#include <xrpl/json/json_value.h>
#include <xrpl/resource/Consumer.h>
#include <xrpl/resource/Gossip.h>
 
#include <boost/utility/string_view.hpp>
 
namespace xrpl::Resource {

class Manager : public beast::PropertyStream::Source
{
protected:
    Manager();
 
public:
    ~Manager() override = 0;

    virtual Consumer
    newInboundEndpoint(beast::IP::Endpoint const& address) = 0;
    virtual Consumer
    newInboundEndpoint(
        beast::IP::Endpoint const& address,
        bool const proxy,
        std::string_view forwardedFor) = 0;

    virtual Consumer
    newOutboundEndpoint(beast::IP::Endpoint const& address) = 0;

    virtual Consumer
    newUnlimitedEndpoint(beast::IP::Endpoint const& address) = 0;

    virtual Gossip
    exportConsumers() = 0;

    virtual json::Value
    getJson() = 0;
    virtual json::Value
    getJson(int threshold) = 0;

    virtual void
    importConsumers(std::string const& origin, Gossip const& gossip) = 0;
};
 
//------------------------------------------------------------------------------
 
std::unique_ptr<Manager>
makeManager(beast::insight::Collector::ptr const& collector, beast::Journal journal);
 
}  // namespace xrpl::Resource