IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-16 17:34:52 -06:00
Code Issues Packages Projects Releases Wiki Activity

prototype metrics summarizer

Browse Source
This commit is contained in:
Jonathan Shook 2020-12-09 16:25:30 -06:00
parent 1d107d8754
commit c83f4d87da
1 changed files with 42 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
engine-clients/src/main/java/io/nosqlbench/engine/clients/grafana/analyzer/GrafanaRegionAnalyzer.java Normal file
View File

@ -0,0 +1,42 @@
package io.nosqlbench.engine.clients.grafana.analyzer;
import io.nosqlbench.engine.clients.grafana.By;
import io.nosqlbench.engine.clients.grafana.GrafanaClient;
import io.nosqlbench.engine.clients.grafana.GrafanaClientConfig;
import io.nosqlbench.engine.clients.grafana.transfer.Annotations;
import io.nosqlbench.engine.clients.grafana.transfer.DashboardResponse;
import io.nosqlbench.engine.clients.grafana.transfer.GrafanaAnnotation;
import io.nosqlbench.nb.api.SystemId;
import java.nio.file.Path;
import java.util.Comparator;
import java.util.List;
import java.util.function.Supplier;
import java.util.stream.Collectors;
public class GrafanaRegionAnalyzer {
public static void main(String[] args) {
GrafanaClientConfig ccfg = new GrafanaClientConfig();
ccfg.setBaseUri("http://18.191.247.162:3000/");
GrafanaClient gclient = new GrafanaClient(ccfg);
Supplier<String> namer = () -> "nosqlbench-" + SystemId.getNodeId() + "-" + System.currentTimeMillis();
gclient.cacheApiToken(namer, "Admin", Long.MAX_VALUE, Path.of("grafana_apikey"), "admin", "admin");
DashboardResponse dashboardResponse = gclient.getDashboardByUid("aIIX1f6Wz");
Annotations annotations = gclient.findAnnotations(By.tag("appname:nosqlbench,layer:Activity"));
List<GrafanaAnnotation> mainActivities = annotations.stream()
.filter(s -> s.getTagMap().getOrDefault("alias", "").contains("main"))
.sorted(Comparator.comparing(t -> t.getTime()))
.collect(Collectors.toList());
System.out.println("end");
GrafanaAnnotation last = mainActivities.get(mainActivities.size() - 1);
long start = last.getTime();
long end = last.getTimeEnd();
}
}