feat(observability): Update log levels for transforms (vectordotdev#4235

)

Signed-off-by: Spencer Gilbert <spencer.gilbert@gmail.com>
Signed-off-by: Brian Menges <brian.menges@anaplan.com>

src/internal_events/add_tags.rs

@@ -17,7 +17,7 @@ pub struct AddTagsTagOverwritten<'a> {
 
 impl<'a> InternalEvent for AddTagsTagOverwritten<'a> {
     fn emit_logs(&self) {
-        error!(message = "Tag overwritten.", %self.tag, rate_limit_secs = 30);
+        debug!(message = "Tag overwritten.", %self.tag, rate_limit_secs = 30);
     }
 }
 
@@ -28,6 +28,6 @@ pub struct AddTagsTagNotOverwritten<'a> {
 
 impl<'a> InternalEvent for AddTagsTagNotOverwritten<'a> {
     fn emit_logs(&self) {
-        error!(message = "Tag not overwritten.", %self.tag, rate_limit_secs = 30);
+        debug!(message = "Tag not overwritten.", %self.tag, rate_limit_secs = 30);
     }
 }

src/internal_events/grok_parser.rs

@@ -42,7 +42,7 @@ pub(crate) struct GrokParserMissingField<'a> {
 
 impl InternalEvent for GrokParserMissingField<'_> {
     fn emit_logs(&self) {
-        debug!(message = "Field does not exist.", field = %self.field);
+        warn!(message = "Field does not exist.", field = %self.field);
     }
 
     fn emit_metrics(&self) {
@@ -60,7 +60,7 @@ pub(crate) struct GrokParserConversionFailed<'a> {
 
 impl<'a> InternalEvent for GrokParserConversionFailed<'a> {
     fn emit_logs(&self) {
-        debug!(
+        warn!(
             message = "Could not convert types.",
             name = %self.name,
             error = %self.error,

src/internal_events/regex_parser.rs

@@ -41,7 +41,7 @@ pub(crate) struct RegexParserMissingField<'a> {
 
 impl InternalEvent for RegexParserMissingField<'_> {
     fn emit_logs(&self) {
-        debug!(message = "Field does not exist.", field = %self.field);
+        warn!(message = "Field does not exist.", field = %self.field);
     }
 
     fn emit_metrics(&self) {

src/internal_events/remove_fields.rs

@@ -17,6 +17,6 @@ pub struct RemoveFieldsFieldMissing<'a> {
 
 impl<'a> InternalEvent for RemoveFieldsFieldMissing<'a> {
     fn emit_logs(&self) {
-        error!(message = "Field did not exist.", %self.field, rate_limit_secs = 30);
+        debug!(message = "Field did not exist.", %self.field, rate_limit_secs = 30);
     }
 }

src/internal_events/rename_fields.rs

@@ -17,7 +17,7 @@ pub struct RenameFieldsFieldOverwritten<'a> {
 
 impl<'a> InternalEvent for RenameFieldsFieldOverwritten<'a> {
     fn emit_logs(&self) {
-        error!(message = "Field overwritten.", %self.field, rate_limit_secs = 30);
+        debug!(message = "Field overwritten.", %self.field, rate_limit_secs = 30);
     }
 }
 
@@ -28,6 +28,6 @@ pub struct RenameFieldsFieldDoesNotExist<'a> {
 
 impl<'a> InternalEvent for RenameFieldsFieldDoesNotExist<'a> {
     fn emit_logs(&self) {
-        error!(message = "Field did not exist.", %self.field, rate_limit_secs = 30);
+        warn!(message = "Field did not exist.", %self.field, rate_limit_secs = 30);
     }
 }

src/internal_events/split.rs

@@ -18,7 +18,7 @@ pub struct SplitFieldMissing<'a> {
 
 impl<'a> InternalEvent for SplitFieldMissing<'a> {
     fn emit_logs(&self) {
-        debug!(
+        warn!(
             message = "Field does not exist.",
             field = %self.field,
             rate_limit_secs = 10
@@ -38,7 +38,7 @@ pub struct SplitConvertFailed<'a> {
 
 impl<'a> InternalEvent for SplitConvertFailed<'a> {
     fn emit_logs(&self) {
-        debug!(
+        warn!(
             message = "Could not convert types.",
             field = %self.field,
             error = %self.error,

src/internal_events/tag_cardinality_limit.rs

@@ -20,7 +20,7 @@ pub(crate) struct TagCardinalityLimitRejectingEvent<'a> {
 
 impl<'a> InternalEvent for TagCardinalityLimitRejectingEvent<'a> {
     fn emit_logs(&self) {
-        error!(
+        debug!(
             message = "Event containing tag with new value after hitting configured 'value_limit'; discarding event.",
             tag_key = self.tag_key,
             tag_value = self.tag_value,
@@ -40,7 +40,7 @@ pub(crate) struct TagCardinalityLimitRejectingTag<'a> {
 
 impl<'a> InternalEvent for TagCardinalityLimitRejectingTag<'a> {
     fn emit_logs(&self) {
-        warn!(
+        debug!(
             message = "Rejecting tag after hitting configured 'value_limit'.",
             tag_key = self.tag_key,
             tag_value = self.tag_value,
@@ -59,7 +59,7 @@ pub(crate) struct TagCardinalityValueLimitReached<'a> {
 
 impl<'a> InternalEvent for TagCardinalityValueLimitReached<'a> {
     fn emit_logs(&self) {
-        warn!(
+        debug!(
             "Value_limit reached for key {}. New values for this key will be rejected.",
             key = self.key,
         );

src/internal_events/tokenizer.rs

@@ -18,7 +18,7 @@ pub(crate) struct TokenizerFieldMissing<'a> {
 
 impl<'a> InternalEvent for TokenizerFieldMissing<'a> {
     fn emit_logs(&self) {
-        debug!(
+        warn!(
             message = "Field does not exist.",
             field = %self.field,
             rate_limit_secs = 10
@@ -38,7 +38,7 @@ pub(crate) struct TokenizerConvertFailed<'a> {
 
 impl<'a> InternalEvent for TokenizerConvertFailed<'a> {
     fn emit_logs(&self) {
-        debug!(
+        warn!(
             message = "Could not convert types.",
             field = %self.field,
             error = %self.error,