NetworkTelemetry.h

浏览该文件的文档.

#pragma once
 
#include <cstddef>
#include <cstdint>
#include <deque>
#include <vector>
#include "common/Export.h"
#include "editing/EditingProtocol.h"
namespace eve::network { class Network; }
namespace eve::network_editing {
using DiagnosticSeverity=editing::DiagnosticSeverity; using EditorDiagnostic=editing::Diagnostic;
using editing::Result; using EditorStatus=editing::Status;
using RuleId=editing::RuleId;
struct NetworkTelemetrySample {
    std::uint64_t revision=0,sentBytes=0,receivedBytes=0,completions=0,errors=0,connections=0;
    std::size_t watchedTcp=0,watchedUdp=0,channels=0,queuedTcpBytes=0;
    double timeSeconds=0,sendBytesPerSecond=0,receiveBytesPerSecond=0,errorRate=0;
};
class EVENGINE_API_BACKENDS NetworkTelemetryModel {
public:
    explicit NetworkTelemetryModel(std::size_t capacity=300);
    Result<void> ingest(NetworkTelemetrySample);
    const std::deque<NetworkTelemetrySample>& samples() const { return samples_; }
    std::vector<EditorDiagnostic> diagnostics() const;
    void clear();
private:
    std::size_t capacity_;
    std::deque<NetworkTelemetrySample> samples_;
};
class NetworkTelemetryCollector {
public:
    Result<void> collect(network::Network*,double,NetworkTelemetryModel&) const;
};
} // namespace eve::network_editing