feat(server): adds event ingestion count to createeventsresponse

ethpandaops · Nov 4, 2024 · f657c6e · f657c6e
1 parent eeb551b
commit f657c6e
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
 }