metrics.hpp

Go to the documentation of this file.

#pragma once
 
 
#include <prom/prom.hpp>
 
#include <memory>
 
namespace conduit::metrics {
 
inline std::shared_ptr<prom::Scope>& scope() {
    static std::shared_ptr<prom::Scope> sc =
        prom::scope("conduit",
                    prom::ScopeConfig{.prefix = "conduit_",
                                      .display = comms::DisplayInfo{
                                          .name = "conduit",
                                          .description = "conduit event-bus metrics.",
                                      }});
    return sc;
}
 
inline prom::Counter& events_published() {
    static prom::Counter m =
        scope()->counter({.name = "events_published_total",
                          .help = "Envelopes that entered the dispatch pipeline."});
    return m;
}
 
inline prom::Counter& events_dropped() {
    static prom::Counter m = scope()->counter(
        {.name = "events_dropped_total",
         .help = "Envelopes dropped before dispatch (middleware veto or routing conflict)."});
    return m;
}
 
inline prom::Counter& listener_invocations() {
    static prom::Counter m =
        scope()->counter({.name = "listener_invocations_total",
                          .help = "Listener handler calls during fan-out (per matched listener)."});
    return m;
}
 
inline prom::Counter& listener_errors() {
    static prom::Counter m = scope()->counter(
        {.name = "listener_errors_total", .help = "Listener handlers that threw during fan-out."});
    return m;
}
 
inline prom::Counter& transport_errors() {
    static prom::Counter m = scope()->counter(
        {.name = "transport_errors_total",
         .help = "Transport-level inbound failures (e.g. an undecodable message)."});
    return m;
}
 
inline prom::Gauge& listeners() {
    static prom::Gauge m = scope()->gauge(
        {.name = "listeners", .help = "Live listener subscriptions registered on a bus."});
    return m;
}
 
inline prom::Histogram& dispatch_seconds() {
    static prom::Histogram m = scope()->histogram(
        {.name = "dispatch_seconds",
         .help =
             "Wall-clock seconds from publish to the end of the synchronous dispatch pipeline."});
    return m;
}
 
}  // namespace conduit::metrics