Add benchmark for compression

observIQ · Aug 11, 2020 · 803080d · 803080d
1 parent dd0329c
commit 803080d
Showing 1 changed file with 18 additions and 2 deletions.
diff --git a/operator/builtin/output/google_cloud_test.go b/operator/builtin/output/google_cloud_test.go
@@ -292,8 +292,9 @@ func startServer() (*grpc.ClientConn, chan *logpb.WriteLogEntriesRequest, func()
 }
 
 type googleCloudOutputBenchmark struct {
-	name  string
-	entry *entry.Entry
+	name      string
+	entry     *entry.Entry
+	configMod func(*GoogleCloudOutputConfig)
 }
 
 func (g *googleCloudOutputBenchmark) Run(b *testing.B) {
@@ -345,27 +346,31 @@ func BenchmarkGoogleCloudOutput(b *testing.B) {
 				Timestamp: t,
 				Record:    "test",
 			},
+			nil,
 		},
 		{
 			"MapRecord",
 			&entry.Entry{
 				Timestamp: t,
 				Record:    mapOfSize(1, 0),
 			},
+			nil,
 		},
 		{
 			"LargeMapRecord",
 			&entry.Entry{
 				Timestamp: t,
 				Record:    mapOfSize(30, 0),
 			},
+			nil,
 		},
 		{
 			"DeepMapRecord",
 			&entry.Entry{
 				Timestamp: t,
 				Record:    mapOfSize(1, 10),
 			},
+			nil,
 		},
 		{
 			"Labels",
@@ -376,6 +381,17 @@ func BenchmarkGoogleCloudOutput(b *testing.B) {
 					"test": "val",
 				},
 			},
+			nil,
+		},
+		{
+			"Compression",
+			&entry.Entry{
+				Timestamp: t,
+				Record:    "compressiblecompressiblecompressiblecompressiblecompressiblecompressiblecompressible",
+			},
+			func(cfg *GoogleCloudOutputConfig) {
+				cfg.UseCompression = true
+			},
 		},
 	}