feature: trace by event

awakari · Aug 4, 2023 · 84b23e1 · 84b23e1
1 parent 9430a25
commit 84b23e1
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 15 deletions.
diff --git a/helm/core/values-tracing.yaml b/helm/core/values-tracing.yaml
@@ -7,7 +7,13 @@ evaluator:
     collector:
       uri: "http://core-jaeger-collector:14268/api/traces"
 
-writer:
+matches:
+  tracing:
+    enabled: true
+    collector:
+      uri: "http://core-jaeger-collector:14268/api/traces"
+
+reader:
   tracing:
     enabled: true
     collector:
@@ -18,3 +24,9 @@ resolver:
     enabled: true
     collector:
       uri: "http://core-jaeger-collector:14268/api/traces"
+
+writer:
+  tracing:
+    enabled: true
+    collector:
+      uri: "http://core-jaeger-collector:14268/api/traces"
diff --git a/test/perf_e2e_test.go b/test/perf_e2e_test.go
@@ -107,12 +107,12 @@ func Test_Perf_EndToEnd(t *testing.T) {
 		//    batchSize: 1,
 		//    duration:  200 * time.Second,
 		//},
-		//"subCount = 10, writeRate = 10": {
-		//    subCount:  10,
-		//    writeRate: 10,
-		//    batchSize: 2,
-		//    duration:  200 * time.Second,
-		//},
+		"subCount = 10, writeRate = 10": {
+			subCount:  10,
+			writeRate: 10,
+			batchSize: 2,
+			duration:  200 * time.Second,
+		},
 		//"subCount = 10, writeRate = 20": {
 		//    subCount:  10,
 		//    writeRate: 20,
@@ -174,12 +174,12 @@ func Test_Perf_EndToEnd(t *testing.T) {
 		//    batchSize: 16,
 		//    duration:  200 * time.Second,
 		//},
-		//"subCount = 100, writeRate = 100": {
-		//    subCount:  100,
-		//    writeRate: 100,
-		//    batchSize: 16,
-		//    duration:  200 * time.Second,
-		//},
+		"subCount = 100, writeRate = 100": {
+			subCount:  100,
+			writeRate: 100,
+			batchSize: 16,
+			duration:  200 * time.Second,
+		},
 		//"subCount = 100, writeRate = 200": {
 		//    subCount:  100,
 		//    writeRate: 200,
@@ -411,7 +411,7 @@ func Test_Perf_MaxRate_WriteRead(t *testing.T) {
 			subCount:  1,
 			writeRate: 2,
 			batchSize: 1,
-			duration:  300 * time.Second,
+			duration:  100 * time.Second,
 		},
 		"subCount = 1, writeRate = 5": {
 			subCount:  1,
@@ -729,7 +729,7 @@ func Test_Perf_MaxRate_WriteRead(t *testing.T) {
 			fmt.Printf("Rate: %f, Latency: 50th=%f, 90th=%f, 99th=%f [s]\n", float64(len(readTsByEvtId))/float64(timeRead), lat50th, lat90th, lat99th)
 
 			t.Log("wait until writer queue is consumed completely...")
-			time.Sleep(5 * time.Minute)
+			time.Sleep(10 * time.Second)
 
 			// clean matches
 			matchesCleanOutput, err := exec.Command("grpcurl", "-plaintext", "-d", "{}", "localhost:50054", "awakari.matches.Service/Clean").Output()