benchmark: add metadata value to benchmarks

farbodahm · Sep 1, 2024 · 2289915 · 2289915
1 parent 13eb677
commit 2289915
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/utils/test_utils.go b/pkg/utils/test_utils.go
@@ -51,6 +51,7 @@ func HeavyRecordSchema() Schema {
 // with given length.
 // You can use this for benchmark tests.
 func NewHeavyRecord(string_length int) Record {
+	t := time.Now()
 	return Record{
 		Key: GenerateRandomString(string_length),
 		Data: ValueMap{
@@ -75,5 +76,9 @@ func NewHeavyRecord(string_length int) Record {
 			"field_19": String{Val: GenerateRandomString(string_length)},
 			"field_20": String{Val: GenerateRandomString(string_length)},
 		},
+		Metadata: Metadata{
+			Stream:    "benchmark",
+			Timestamp: t,
+		},
 	}
 }