ORE Studio 0.0.4
Loading...
Searching...
No Matches
nats_stream_sample.hpp
1/* -*- mode: c++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*-
2 *
3 * Copyright (C) 2026 Marco Craveiro <marco.craveiro@gmail.com>
4 *
5 * This program is free software; you can redistribute it and/or modify it under
6 * the terms of the GNU General Public License as published by the Free Software
7 * Foundation; either version 3 of the License, or (at your option) any later
8 * version.
9 *
10 * This program is distributed in the hope that it will be useful, but WITHOUT
11 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
12 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
13 * details.
14 *
15 * You should have received a copy of the GNU General Public License along with
16 * this program; if not, write to the Free Software Foundation, Inc., 51
17 * Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
18 *
19 */
20#ifndef ORES_TELEMETRY_DOMAIN_NATS_STREAM_SAMPLE_HPP
21#define ORES_TELEMETRY_DOMAIN_NATS_STREAM_SAMPLE_HPP
22
23#include <chrono>
24#include <cstdint>
25#include <string>
26
28
36struct nats_stream_sample final {
42 std::chrono::system_clock::time_point sampled_at;
43
49 std::string stream_name;
50
52 std::uint64_t messages{0};
53
55 std::uint64_t bytes{0};
56
63};
64
65}
66
67#endif
Domain types for telemetry and observability.
Definition attribute_value.hpp:29
A single point-in-time sample of a JetStream stream's metrics.
Definition nats_stream_sample.hpp:36
int consumer_count
Number of active consumers on this stream.
Definition nats_stream_sample.hpp:62
std::chrono::system_clock::time_point sampled_at
When this sample was taken.
Definition nats_stream_sample.hpp:42
std::uint64_t messages
Number of messages currently stored in the stream.
Definition nats_stream_sample.hpp:52
std::uint64_t bytes
Total bytes currently stored in the stream.
Definition nats_stream_sample.hpp:55
std::string stream_name
JetStream stream name (e.g. "ORES_TRADES").
Definition nats_stream_sample.hpp:49