Add StatusCode to Sent EventInfo

Signed-off-by: Pierangelo Di Pilato <[email protected]>
knative-extensions · Jun 14, 2024 · cb22810 · cb22810
1 parent 199a526
commit cb22810
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/pkg/eventshub/sender/sender.go b/pkg/eventshub/sender/sender.go
@@ -233,7 +233,7 @@ func Start(ctx context.Context, logs *eventshub.EventLogs, clientOpts ...eventsh
 		span.End()
 
 		// Publish sent event info
-		if err := logs.Vent(env.sentInfo(event, req, err)); err != nil {
+		if err := logs.Vent(env.sentInfo(event, req, res, err)); err != nil {
 			return fmt.Errorf("cannot forward event info: %w", err)
 		}
 
@@ -303,7 +303,7 @@ func (g *generator) peerCertificatesReceived(counter uint64, state tls.Connectio
 	}
 }
 
-func (g *generator) sentInfo(event *cloudevents.Event, req *nethttp.Request, err error) eventshub.EventInfo {
+func (g *generator) sentInfo(event *cloudevents.Event, req *nethttp.Request, res *nethttp.Response, err error) eventshub.EventInfo {
 	var eventId string
 	if event != nil {
 		eventId = event.ID()
@@ -330,6 +330,9 @@ func (g *generator) sentInfo(event *cloudevents.Event, req *nethttp.Request, err
 		Sequence: uint64(g.sequence),
 		SentId:   eventId,
 	}
+	if res != nil {
+		sentEventInfo.StatusCode = res.StatusCode
+	}
 
 	sentHeaders := make(nethttp.Header)
 	for k, v := range req.Header {