support value size type

streamnative · Jul 20, 2024 · 228ed06 · 228ed06
1 parent 3386928
commit 228ed06
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/perf-ycsb/src/main/java/io/streamnative/oxia/client/perf/ycsb/Worker.java b/perf-ycsb/src/main/java/io/streamnative/oxia/client/perf/ycsb/Worker.java
@@ -135,24 +135,28 @@ public Worker(WorkerOptions options, OpenTelemetry openTelemetry) {
         this.operationWriteSuccessAttributes =
                 Attributes.builder()
                         .put("type", "write")
+                        .put("value.size", options.valueSize)
                         .put("worker", options.workerName)
                         .put("response", "success")
                         .build();
         this.operationWriteFailedAttributes =
                 Attributes.builder()
                         .put("type", "write")
+                        .put("value.size", options.valueSize)
                         .put("worker", options.workerName)
                         .put("response", "failed")
                         .build();
         this.operationReadSuccessAttributes =
                 Attributes.builder()
                         .put("type", "read")
+                        .put("value.size", options.valueSize)
                         .put("worker", options.workerName)
                         .put("response", "success")
                         .build();
         this.operationReadFailedAttributes =
                 Attributes.builder()
                         .put("type", "read")
+                        .put("value.size", options.valueSize)
                         .put("worker", options.workerName)
                         .put("response", "failed")
                         .build();