Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commitb0a4f20

Browse files
authored
Grafana metrics post (#80)
1 parentf920b27 commitb0a4f20

File tree

2 files changed

+34
-21
lines changed

2 files changed

+34
-21
lines changed

‎stubbornjava-common/src/main/java/com/stubbornjava/common/Metrics.java‎

Lines changed: 2 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -7,17 +7,14 @@
77

88
importcom.amazonaws.util.EC2MetadataUtils;
99
importcom.codahale.metrics.Meter;
10-
importcom.codahale.metrics.MetricFilter;
1110
importcom.codahale.metrics.MetricRegistry;
1211
importcom.codahale.metrics.Timer;
13-
importcom.codahale.metrics.graphite.GraphiteReporter;
1412
importcom.codahale.metrics.jvm.CachedThreadStatesGaugeSet;
1513
importcom.codahale.metrics.jvm.GarbageCollectorMetricSet;
1614
importcom.codahale.metrics.jvm.MemoryUsageGaugeSet;
1715
importcom.codahale.metrics.logback.InstrumentedAppender;
1816

1917
importch.qos.logback.classic.LoggerContext;
20-
importokhttp3.OkHttpClient;
2118

2219
// {{start:metrics}}
2320
publicclassMetrics {
@@ -37,24 +34,8 @@ public class Metrics {
3734
metrics.start();
3835
root.addAppender(metrics);
3936

40-
41-
// Graphite reporter to Grafana Cloud
42-
OkHttpClientclient =newOkHttpClient.Builder()
43-
//.addNetworkInterceptor(HttpClient.getLoggingInterceptor())
44-
.build();
45-
46-
StringgraphiteHost =Configs.properties().getString("metrics.graphite.host");
47-
StringgrafanaApiKey =Configs.properties().getString("metrics.grafana.api_key");
48-
finalGraphiteHttpSendergraphite =newGraphiteHttpSender(client,graphiteHost,grafanaApiKey);
49-
finalGraphiteReporterreporter =GraphiteReporter.forRegistry(registry)
50-
.prefixedWith(metricPrefix("stubbornjava"))
51-
.convertRatesTo(TimeUnit.MINUTES)
52-
.convertDurationsTo(TimeUnit.MILLISECONDS)
53-
.filter(MetricFilter.ALL)
54-
.build(graphite);
55-
reporter.start(10,TimeUnit.SECONDS);
56-
5737
// Register reporters here.
38+
MetricsReporters.startReporters(registry);
5839
}
5940

6041
publicstaticMetricRegistryregistry() {
@@ -69,7 +50,7 @@ public static Meter meter(String first, String... keys) {
6950
returnregistry.meter(MetricRegistry.name(first,keys));
7051
}
7152

72-
privatestaticStringmetricPrefix(Stringapp) {
53+
staticStringmetricPrefix(Stringapp) {
7354
Envenv =Env.get();
7455
Stringhost =env ==Env.LOCAL ?"localhost" :getHost();
7556
Stringprefix =MetricRegistry.name(app,env.getName(),host);
Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
packagecom.stubbornjava.common;
2+
3+
importjava.util.concurrent.TimeUnit;
4+
5+
importcom.codahale.metrics.MetricFilter;
6+
importcom.codahale.metrics.MetricRegistry;
7+
importcom.codahale.metrics.graphite.GraphiteReporter;
8+
9+
importokhttp3.OkHttpClient;
10+
11+
// {{start:reporters}}
12+
classMetricsReporters {
13+
14+
publicstaticvoidstartReporters(MetricRegistryregistry) {
15+
// Graphite reporter to Grafana Cloud
16+
OkHttpClientclient =newOkHttpClient.Builder()
17+
//.addNetworkInterceptor(HttpClient.getLoggingInterceptor())
18+
.build();
19+
20+
StringgraphiteHost =Configs.properties().getString("metrics.graphite.host");
21+
StringgrafanaApiKey =Configs.properties().getString("metrics.grafana.api_key");
22+
finalGraphiteHttpSendergraphite =newGraphiteHttpSender(client,graphiteHost,grafanaApiKey);
23+
finalGraphiteReporterreporter =GraphiteReporter.forRegistry(registry)
24+
.prefixedWith(Metrics.metricPrefix("stubbornjava"))
25+
.convertRatesTo(TimeUnit.MINUTES)
26+
.convertDurationsTo(TimeUnit.MILLISECONDS)
27+
.filter(MetricFilter.ALL)
28+
.build(graphite);
29+
reporter.start(10,TimeUnit.SECONDS);
30+
}
31+
}
32+
// {{end:reporters}}

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp