TxMetrics.h

#pragma once
 
#include <xrpl/json/json_value.h>
 
#include <boost/circular_buffer.hpp>
 
#include <xrpl.pb.h>
 
#include <chrono>
#include <cstdint>
#include <mutex>
 
namespace xrpl::metrics {

struct SingleMetrics
{
    SingleMetrics(bool ptu = true) : perTimeUnit(ptu)
    {
    }
    using clock_type = std::chrono::steady_clock;
    clock_type::time_point intervalStart{clock_type::now()};
    std::uint64_t accum{0};
    std::uint64_t rollingAvg{0};
    std::uint32_t n{0};
    bool perTimeUnit{true};
    boost::circular_buffer<std::uint64_t> rollingAvgAggregate{30, 0ull};
    void
    addMetrics(std::uint32_t val);
};

struct MultipleMetrics
{
    MultipleMetrics(bool ptu1 = true, bool ptu2 = true) : m1(ptu1), m2(ptu2)
    {
    }
 
    SingleMetrics m1;
    SingleMetrics m2;
    void
    addMetrics(std::uint32_t val2);
    void
    addMetrics(std::uint32_t val1, std::uint32_t val2);
};

struct TxMetrics
{
    mutable std::mutex mutex;
    // TMTransaction bytes and count per second
    MultipleMetrics tx;
    // TMHaveTransactions bytes and count per second
    MultipleMetrics haveTx;
    // TMGetLedger bytes and count per second
    MultipleMetrics getLedger;
    // TMLedgerData bytes and count per second
    MultipleMetrics ledgerData;
    // TMTransactions bytes and count per second
    MultipleMetrics transactions;
    // Peers selected to relay in each transaction sample average
    SingleMetrics selectedPeers{false};
    // Peers suppressed to relay in each transaction sample average
    SingleMetrics suppressedPeers{false};
    // Peers with tx reduce-relay feature not enabled
    SingleMetrics notEnabled{false};
    // TMTransactions number of transactions count per second
    SingleMetrics missingTx;
    void
    addMetrics(protocol::MessageType type, std::uint32_t val);
    void
    addMetrics(std::uint32_t selected, std::uint32_t suppressed, std::uint32_t notEnabled);
    void
    addMetrics(std::uint32_t missing);
    json::Value
    json() const;
};
 
}  // namespace xrpl::metrics