Merge pull request #405 from ethpandaops/debug/additional-event-count…

…-logging feat(server): adds event ingestion count to createeventsresponse
ethpandaops · Nov 4, 2024 · 813387f · 813387f
2 parents eeb551b + f657c6e
commit 813387f
Show file tree

Hide file tree

Showing 4 changed files with 2,297 additions and 2,271 deletions.
diff --git a/pkg/output/xatu/exporter.go b/pkg/output/xatu/exporter.go
@@ -159,7 +159,10 @@ func (e *ItemExporter) sendUpstream(ctx context.Context, items []*pb.DecoratedEv
 		return err
 	}
 
-	logCtx.WithField("response", rsp).Debug("Received response from Xatu sink")
+	logCtx.WithFields(logrus.Fields{
+		"events_ingested": rsp.GetEventsIngested().GetValue(),
+		"events_sent":     len(items),
+	}).Debug("Received response from Xatu sink")
 
 	return nil
 }