Add additional check for "msg" for skip log (#16)

Canva · May 24, 2023 · b37c8ba · b37c8ba
1 parent 68485c3
commit b37c8ba
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/enricher/eks/eks.go b/enricher/eks/eks.go
@@ -35,7 +35,7 @@ var _ enricher.IEnricher = (*Enricher)(nil)
 
 func (e Enricher) EnrichRecord(r map[interface{}]interface{}, t time.Time) map[interface{}]interface{} {
 	// Drop log if "log" field is empty
-	if r[mappings.LOG_FIELD_NAME] == nil {
+	if r[mappings.LOG_FIELD_NAME] == nil && r[mappings.MSG_FIELD_NAME] == nil {
 		return nil
 	}
 

diff --git a/enricher/mappings/mappings.go b/enricher/mappings/mappings.go
@@ -6,6 +6,7 @@ const (
 
 const (
 	LOG_FIELD_NAME = "log"
+	MSG_FIELD_NAME = "message"
 )
 
 const (
-Original file line number
+Diff line change
@@ Expand Up / @@ -6,6 +6,7 @@ const ( @@
     const (
     	LOG_FIELD_NAME = "log"
+    	MSG_FIELD_NAME = "message"
     )
     const (
@@ Expand Down @@