GraphRunStats Struct

Per-node, per-stream telemetry collector for a running GraphRun. More...

Declaration

struct simaai::neat::graph::GraphRunStats { ... }

Included Headers

#include <GraphRun.h>

Public Member Functions Index

void	record (NodeId node_id, const Sample &sample)
	Record a single sample arriving at node_id. Thread-safe. More...
std::vector< Snapshot >	snapshot () const
	Take a consistent snapshot of all per-node stats. More...
bool	empty () const
	True iff no samples have been recorded yet. More...
std::unordered_map< std::string, int64_t >	stream_counts (const std::vector< NodeId > &nodes={}) const
	Aggregate per-stream counts across nodes (or all nodes if empty). More...
bool	has_missing_streams (const std::unordered_set< std::string > &expected, const std::vector< NodeId > &nodes={}) const
	True iff any of expected stream-ids has zero samples on the given nodes. More...
std::string	missing_streams_list (const std::unordered_set< std::string > &expected, const std::vector< NodeId > &nodes={}) const
	Comma-separated list of expected streams that haven't been seen — for diagnostics. More...

Private Member Attributes Index

std::mutex	mu_
std::unordered_map< NodeId, NodeStat >	nodes_

Description

Per-node, per-stream telemetry collector for a running GraphRun.

Records sample counts and first/last timestamps per output stream, per node. Used by PullSession and the various emit_*_summary() helpers.

Definition at line 90 of file GraphRun.h.

Public Member Functions

empty()

bool simaai::neat::graph::GraphRunStats::empty ()

True iff no samples have been recorded yet.

Definition at line 124 of file GraphRun.h.

has_missing_streams()

bool simaai::neat::graph::GraphRunStats::has_missing_streams (const std::unordered_set< std::string > & expected, const std::vector< NodeId > & nodes={})

True iff any of expected stream-ids has zero samples on the given nodes.

Definition at line 129 of file GraphRun.h.

missing_streams_list()

std::string simaai::neat::graph::GraphRunStats::missing_streams_list (const std::unordered_set< std::string > & expected, const std::vector< NodeId > & nodes={})

Comma-separated list of expected streams that haven't been seen — for diagnostics.

Definition at line 132 of file GraphRun.h.

record()

void simaai::neat::graph::GraphRunStats::record (NodeId node_id, const Sample & sample)

Record a single sample arriving at node_id. Thread-safe.

Definition at line 120 of file GraphRun.h.

snapshot()

std::vector< Snapshot > simaai::neat::graph::GraphRunStats::snapshot ()

Take a consistent snapshot of all per-node stats.

Definition at line 122 of file GraphRun.h.

stream_counts()

std::unordered_map< std::string, int64_t > simaai::neat::graph::GraphRunStats::stream_counts (const std::vector< NodeId > & nodes={})

Aggregate per-stream counts across nodes (or all nodes if empty).

Definition at line 127 of file GraphRun.h.

Private Member Attributes

mu_

std::mutex simaai::neat::graph::GraphRunStats::mu_

mutable

Definition at line 136 of file GraphRun.h.

136 mutable std::mutex mu_;

nodes_

std::unordered_map<NodeId, NodeStat> simaai::neat::graph::GraphRunStats::nodes_

Definition at line 137 of file GraphRun.h.

137 std::unordered_map<NodeId, NodeStat> nodes_;

---

The documentation for this struct was generated from the following file:

• GraphRun.h

---

Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.8.