Preserve the record ID in forwarded log records.

Author: ericsnowcurrently

api/logstream/logstream.go

@@ -121,6 +121,7 @@ func (ls *LogStream) Close() error {
 // See the counterpart in apiserver/logstream.go.
 func recordFromAPI(apiRec params.LogStreamRecord, controllerUUID string) (logfwd.Record, error) {
 	rec := logfwd.Record{
+		ID:        apiRec.ID,
 		Timestamp: apiRec.Timestamp,
 		Message:   apiRec.Message,
 	}

logfwd/record.go

@@ -15,6 +15,10 @@ import (
 
 // Record holds all the information for a single log record.
 type Record struct {
+	// ID identifies the record and its position in a sequence
+	// of records.
+	ID int64
+
 	// Origin describes what created the record.
 	Origin Origin