Skip to content

Commit

Permalink
r/buffered_protocol: added a missing call to setup metrics
Browse files Browse the repository at this point in the history
Signed-off-by: Michał Maślanka <michal@redpanda.com>
  • Loading branch information
mmaslankaprv committed Dec 12, 2024
1 parent 1b8b49b commit 04aec5e
Showing 1 changed file with 3 additions and 7 deletions.
10 changes: 3 additions & 7 deletions src/v/raft/buffered_protocol.cc
Original file line number Diff line number Diff line change
Expand Up @@ -253,6 +253,7 @@ append_entries_queue::append_entries_queue(
}
_current_max_inflight_requests = new_value;
});
setup_internal_metrics();
// start dispatch loop
ssx::repeat_until_gate_closed(
_gate,
Expand Down Expand Up @@ -357,7 +358,7 @@ void append_entries_queue::setup_internal_metrics() {
}
sm::label_instance target_node_id_label("target_node_id", _target_node);
_internal_metrics.add_group(
prometheus_sanitize::metrics_name("raft::buffered::protocol"),
prometheus_sanitize::metrics_name("raft:buffered:protocol"),
{sm::make_gauge(
"inflight_requests",
[this] { return inflight_requests(); },
Expand All @@ -374,12 +375,7 @@ void append_entries_queue::setup_internal_metrics() {
[this] { return _requests.size(); },
sm::description(
"Total number of append entries requests in the queue"),
{target_node_id_label}),
sm::make_histogram(
"append_entries_request_latency",
sm::description("Latency of append entries requests"),
{target_node_id_label},
[this] { return _hist.internal_histogram_logform(); })});
{target_node_id_label})});
}

void append_entries_queue::setup_public_metrics() {
Expand Down

0 comments on commit 04aec5e

Please sign in to comment.