Struct GraphStats 

pub struct GraphStats {
    pub collection: String,
    pub node_count: u64,
    pub edge_count: u64,
    pub distinct_label_count: u64,
    pub labels: Vec<(String, u64)>,
}

Aggregate stats for a single graph collection (or the full edge store when no collection is specified).

Returned by [NodeDb::graph_stats]. Wire-safe: serializes to/from MessagePack so the value can cross the Data-Plane boundary unchanged.

The node_count field counts distinct node IDs observed as edge endpoints (not necessarily all nodes ever inserted). For Origin, this equals distinct_node_count from the persistent stats table; for Lite, it is derived from the CRDT edge store at query time.

Fields

collection: String

Name of the collection (or "__edges" on Lite when no collection is supplied).

node_count: u64

Distinct node IDs that appear as an edge source or destination.

edge_count: u64

Total number of edges in the collection.

distinct_label_count: u64

Number of distinct edge label strings.

labels: Vec<(String, u64)>

Per-label edge counts, sorted ascending by label name.

Implementations

impl GraphStats

pub const EXPECTED_COLUMNS: [&'static str; 5]

Column names of the wire row shape produced by SHOW GRAPH STATS [<'collection'>]. Single source of truth — the parser validates against this, and clients use it to build the columns slice in tests so the two never drift.

pub fn zero(collection: impl Into<String>) -> Self

pub fn parse_show_stats_response( columns: &[String], rows: &[Vec<Value>], ) -> NodeDbResult<Vec<Self>>

Parse the wire shape produced by SHOW GRAPH STATS [<'collection'>] into a vec of GraphStats, one entry per row. Used by both the native and the pgwire remote clients — keeping a single parser here is what makes the wire_shape: smoke-probe error messages a meaningful diagnostic rather than a coincidence between two copies.

Expected columns: (collection, node_count, edge_count, distinct_label_count, labels), where labels is a JSON array of {"label": str, "count": u64} objects.

Both wire paths can deliver count cells as Value::Integer (extended-query / native typed) or Value::String (pgwire simple query text protocol); both shapes are accepted.

Column-shape mismatches surface as errors (this is exactly the bug class the smoke probe is designed to trap, so no fallback); empty rows return an empty vec — callers decide how to interpret no rows.

Trait Implementations

impl Clone for GraphStats

fn clone(&self) -> GraphStats

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for GraphStats

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for GraphStats

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'__msgpack_de> FromMessagePack<'__msgpack_de> for GraphStats

fn read<R: Read<'__msgpack_de>>(reader: &mut R) -> Result<Self, Error>

where Self: Sized,

Reads the MessagePack representation of this value from the provided reader.

impl PartialEq for GraphStats

fn eq(&self, other: &GraphStats) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for GraphStats

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for GraphStats

impl ToMessagePack for GraphStats

fn write<W: Write>(&self, writer: &mut W) -> Result<(), Error>

Writes the MessagePack representation of this value into the provided writer.