forked from valkey-io/valkey-glide
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: Yury-Fridlyand <[email protected]>
- Loading branch information
1 parent
1bab56a
commit 5fbc4ac
Showing
5 changed files
with
137 additions
and
53 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
102 changes: 102 additions & 0 deletions
102
java/benchmarks/src/main/java/javababushka/benchmarks/utils/Reporting.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,102 @@ | ||
| package javababushka.benchmarks.utils; | ||
|
|
||
| import com.google.gson.Gson; | ||
| import com.google.gson.GsonBuilder; | ||
| import com.google.gson.reflect.TypeToken; | ||
| import java.io.IOException; | ||
| import java.nio.file.Files; | ||
| import java.nio.file.Path; | ||
| import java.util.ArrayList; | ||
| import java.util.Collection; | ||
| import java.util.Map; | ||
| import lombok.Getter; | ||
|
|
||
| public class Reporting { | ||
|
|
||
| public static void WriteJson( | ||
| Map<ChosenAction, LatencyResults> calculatedResults, | ||
| String resultsFile, | ||
| int dataSize, | ||
| String client, | ||
| int clientCount, | ||
| int numOfTasks, | ||
| double tps) { | ||
|
|
||
| try { | ||
| Gson gson = new GsonBuilder().setPrettyPrinting().serializeNulls().create(); | ||
| Collection<Measurements> recordings = new ArrayList<>(); | ||
|
|
||
| Path path = Path.of(resultsFile); | ||
| if (Files.exists(path)) { | ||
| TypeToken<Collection<Measurements>> collectionType = new TypeToken<>() {}; | ||
| var json = new String(Files.readAllBytes(path)); | ||
| recordings = gson.fromJson(json, collectionType); | ||
| } | ||
| var data = new Measurements(); | ||
| data.data_size = dataSize; | ||
| data.client = client; | ||
| data.clientCount = clientCount; | ||
| data.num_of_tasks = numOfTasks; | ||
| data.tps = tps; | ||
| // TODO: is_cluster | ||
|
|
||
| data.get_existing_average_latency = | ||
| calculatedResults.get(ChosenAction.GET_EXISTING).avgLatency; | ||
| data.get_existing_p50_latency = calculatedResults.get(ChosenAction.GET_EXISTING).p50Latency; | ||
| data.get_existing_p90_latency = calculatedResults.get(ChosenAction.GET_EXISTING).p90Latency; | ||
| data.get_existing_p99_latency = calculatedResults.get(ChosenAction.GET_EXISTING).p99Latency; | ||
| data.get_existing_std_dev = calculatedResults.get(ChosenAction.GET_EXISTING).stdDeviation; | ||
|
|
||
| data.get_non_existing_average_latency = | ||
| calculatedResults.get(ChosenAction.GET_NON_EXISTING).avgLatency; | ||
| data.get_non_existing_p50_latency = | ||
| calculatedResults.get(ChosenAction.GET_NON_EXISTING).p50Latency; | ||
| data.get_non_existing_p90_latency = | ||
| calculatedResults.get(ChosenAction.GET_NON_EXISTING).p90Latency; | ||
| data.get_non_existing_p99_latency = | ||
| calculatedResults.get(ChosenAction.GET_NON_EXISTING).p99Latency; | ||
| data.get_non_existing_std_dev = | ||
| calculatedResults.get(ChosenAction.GET_NON_EXISTING).stdDeviation; | ||
|
|
||
| data.set_average_latency = calculatedResults.get(ChosenAction.SET).avgLatency; | ||
| data.set_p50_latency = calculatedResults.get(ChosenAction.SET).p50Latency; | ||
| data.set_p90_latency = calculatedResults.get(ChosenAction.SET).p90Latency; | ||
| data.set_p99_latency = calculatedResults.get(ChosenAction.SET).p99Latency; | ||
| data.set_std_dev = calculatedResults.get(ChosenAction.SET).stdDeviation; | ||
|
|
||
| recordings.add(data); | ||
|
|
||
| Files.write(path, gson.toJson(recordings).getBytes()); | ||
| } catch (IOException e) { | ||
| System.out.printf( | ||
| "Failed to write measurement results into a file '%s': %s%n", | ||
| resultsFile, e.getMessage()); | ||
| e.printStackTrace(); | ||
| } | ||
| } | ||
|
|
||
| @Getter | ||
| public static class Measurements { | ||
| private String client; | ||
| private int clientCount; | ||
| private int data_size; | ||
| private double get_existing_average_latency; | ||
| private double get_existing_p50_latency; | ||
| private double get_existing_p90_latency; | ||
| private double get_existing_p99_latency; | ||
| private double get_existing_std_dev; | ||
| private double get_non_existing_average_latency; | ||
| private double get_non_existing_p50_latency; | ||
| private double get_non_existing_p90_latency; | ||
| private double get_non_existing_p99_latency; | ||
| private double get_non_existing_std_dev; | ||
| private boolean is_cluster; | ||
| private int num_of_tasks; | ||
| private double set_average_latency; | ||
| private double set_p50_latency; | ||
| private double set_p90_latency; | ||
| private double set_p99_latency; | ||
| private double set_std_dev; | ||
| private double tps; | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters