diff --git a/src/config/watcher.rs b/src/config/watcher.rs index 5f02b9d4128b3..1a4bc2f0cc734 100644 --- a/src/config/watcher.rs +++ b/src/config/watcher.rs @@ -147,19 +147,38 @@ pub fn spawn_thread<'a>( .all(|(_, t)| *t == ComponentType::EnrichmentTable) { info!("Only enrichment tables have changed."); - _ = signal_tx.send(crate::signal::SignalTo::ReloadEnrichmentTables).map_err(|error| { - error!(message = "Unable to reload enrichment tables.", cause = %error) - }); + _ = signal_tx + .send(crate::signal::SignalTo::ReloadEnrichmentTables) + .map_err(|error| { + error!( + message = "Unable to reload enrichment tables.", + cause = %error, + internal_log_rate_limit = false, + ) + }); } else { - _ = signal_tx.send(crate::signal::SignalTo::ReloadComponents(changed_components.into_keys().collect())).map_err(|error| { - error!(message = "Unable to reload component configuration. Restart Vector to reload it.", cause = %error) - }); + _ = signal_tx + .send(crate::signal::SignalTo::ReloadComponents( + changed_components.into_keys().collect(), + )) + .map_err(|error| { + error!( + message = "Unable to reload component configuration. Restart Vector to reload it.", + cause = %error, + internal_log_rate_limit = false, + ) + }); } } else { - _ = signal_tx.send(crate::signal::SignalTo::ReloadFromDisk) - .map_err(|error| { - error!(message = "Unable to reload configuration file. Restart Vector to reload it.", cause = %error) - }); + _ = signal_tx + .send(crate::signal::SignalTo::ReloadFromDisk) + .map_err(|error| { + error!( + message = "Unable to reload configuration file. Restart Vector to reload it.", + cause = %error, + internal_log_rate_limit = false, + ) + }); } } else { debug!(message = "Ignoring event.", event = ?event) diff --git a/src/internal_events/aws_ecs_metrics.rs b/src/internal_events/aws_ecs_metrics.rs index eba1fa145e0a8..4589a3eda70d2 100644 --- a/src/internal_events/aws_ecs_metrics.rs +++ b/src/internal_events/aws_ecs_metrics.rs @@ -52,8 +52,9 @@ impl InternalEvent for AwsEcsMetricsParseError<'_> { error_type = error_type::PARSER_FAILED, ); debug!( - message = %format!("Failed to parse response:\\n\\n{}\\n\\n", self.body.escape_debug()), + response = %self.body.escape_debug(), endpoint = %self.endpoint, + "Failed to parse response.", ); counter!("parse_errors_total").increment(1); counter!( diff --git a/src/internal_events/config.rs b/src/internal_events/config.rs index c8fb994c85c94..7c9e80dc87788 100644 --- a/src/internal_events/config.rs +++ b/src/internal_events/config.rs @@ -14,6 +14,7 @@ impl InternalEvent for ConfigReloadRejected { message = "Config reload rejected due to non-reloadable global options.", reason = %self.reason.as_str(), changed_fields = %fields.join(", "), + internal_log_rate_limit = false, ); counter!( @@ -27,6 +28,7 @@ impl InternalEvent for ConfigReloadRejected { message = "Config reload rejected due to failed to compute global diff.", reason = %self.reason.as_str(), error = %err, + internal_log_rate_limit = false, ); counter!( diff --git a/src/internal_events/lua.rs b/src/internal_events/lua.rs index 9d202112fea5b..1770761fda489 100644 --- a/src/internal_events/lua.rs +++ b/src/internal_events/lua.rs @@ -58,6 +58,7 @@ impl InternalEvent for LuaBuildError { error_type = error_type::SCRIPT_FAILED, error_code = lua_build_error_code(&self.error), stage = error_stage::PROCESSING, + internal_log_rate_limit = false, ); counter!( "component_errors_total", diff --git a/src/internal_events/process.rs b/src/internal_events/process.rs index 3d5f3100e6f9d..ce8fbd063f438 100644 --- a/src/internal_events/process.rs +++ b/src/internal_events/process.rs @@ -30,7 +30,8 @@ impl InternalEvent for VectorReloaded<'_> { info!( target: "vector", message = "Vector has reloaded.", - path = ?self.config_paths + path = ?self.config_paths, + internal_log_rate_limit = false, ); counter!("reloaded_total").increment(1); } @@ -43,7 +44,7 @@ impl InternalEvent for VectorStopped { fn emit(self) { info!( target: "vector", - message = "Vector has stopped." + message = "Vector has stopped.", ); counter!("stopped_total").increment(1); } @@ -56,7 +57,7 @@ impl InternalEvent for VectorQuit { fn emit(self) { info!( target: "vector", - message = "Vector has quit." + message = "Vector has quit.", ); counter!("quit_total").increment(1); } @@ -72,6 +73,7 @@ impl InternalEvent for VectorReloadError { error_code = "reload", error_type = error_type::CONFIGURATION_FAILED, stage = error_stage::PROCESSING, + internal_log_rate_limit = false, ); counter!( "component_errors_total", @@ -93,6 +95,7 @@ impl InternalEvent for VectorConfigLoadError { error_code = "config_load", error_type = error_type::CONFIGURATION_FAILED, stage = error_stage::PROCESSING, + internal_log_rate_limit = false, ); counter!( "component_errors_total", @@ -114,6 +117,7 @@ impl InternalEvent for VectorRecoveryError { error_code = "recovery", error_type = error_type::CONFIGURATION_FAILED, stage = error_stage::PROCESSING, + internal_log_rate_limit = false, ); counter!( "component_errors_total", diff --git a/src/sinks/amqp/config.rs b/src/sinks/amqp/config.rs index 9e0a2fb273321..8d7442cb37e70 100644 --- a/src/sinks/amqp/config.rs +++ b/src/sinks/amqp/config.rs @@ -45,6 +45,7 @@ impl AmqpPropertiesConfig { error = %error, error_type = error_type::TEMPLATE_FAILED, stage = error_stage::PROCESSING, + internal_log_rate_limit = false, ); Default::default() });