fix(observability): Fix a few more usages of internal_log_rate_secs (#…

…15041) Signed-off-by: Jesse Szwedko <jesse.szwedko@datadoghq.com> Signed-off-by: Jesse Szwedko <jesse.szwedko@datadoghq.com>
vectordotdev · Nov 1, 2022 · 7a8a270 · 7a8a270
1 parent dcc86f3
commit 7a8a270
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/lib/vector-common/src/internal_event/service.rs b/lib/vector-common/src/internal_event/service.rs
@@ -44,7 +44,7 @@ impl<E: std::fmt::Debug> InternalEvent for CallError<E> {
             request_id = self.request_id,
             error_type = error_type::REQUEST_FAILED,
             stage = error_stage::SENDING,
-            internal_log_rate_secs = true,
+            internal_log_rate_limit = true,
         );
         counter!(
             "component_errors_total", 1,

diff --git a/src/sources/amqp.rs b/src/sources/amqp.rs
@@ -359,7 +359,7 @@ async fn run_amqp_source(
         )
         .await
         .map_err(|error| {
-            error!(message = "Failed to consume.", error = ?error, internal_log_rate_secs = true);
+            error!(message = "Failed to consume.", error = ?error, internal_log_rate_limit = true);
         })?
         .fuse();
     let mut shutdown = shutdown.fuse();