Skip to content

Commit 8c86613

Browse files
committed
test moved and retry metrics
Signed-off-by: Maayan Shani <[email protected]>
1 parent a492769 commit 8c86613

File tree

4 files changed

+586
-440
lines changed

4 files changed

+586
-440
lines changed

glide-core/redis-rs/redis/src/cluster_async/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2836,7 +2836,7 @@ where
28362836
Next::Done => {}
28372837
Next::Retry { request } => {
28382838
// Record retries error metric if telemetry is initialized
2839-
if let Err(e) = GlideOpenTelemetry::record_retries() {
2839+
if let Err(e) = GlideOpenTelemetry::record_retry_attempt() {
28402840
log_error(
28412841
"OpenTelemetry:retry_error",
28422842
format!("Failed to record retry attempt: {}", e),
@@ -2853,7 +2853,7 @@ where
28532853
}
28542854
Next::RetryBusyLoadingError { request, address } => {
28552855
// Record retry attempt metric if telemetry is initialized
2856-
if let Err(e) = GlideOpenTelemetry::record_retries() {
2856+
if let Err(e) = GlideOpenTelemetry::record_retry_attempt() {
28572857
log_error(
28582858
"OpenTelemetry:retry_error",
28592859
format!("Failed to record retry attempt: {}", e),

glide-core/redis-rs/redis/src/cluster_async/pipeline_routing.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ fn add_command_to_node_pipeline_map<C>(
112112
{
113113
if is_retrying {
114114
// Record retry attempt metric if telemetry is initialized
115-
if let Err(e) = GlideOpenTelemetry::record_retries() {
115+
if let Err(e) = GlideOpenTelemetry::record_retry_attempt() {
116116
log_error(
117117
"OpenTelemetry:retry_error",
118118
format!("Failed to record retry attempt: {}", e),

0 commit comments

Comments
 (0)