1919
2020package org .apache .ranger .rest ;
2121
22- import java .lang .management .ManagementFactory ;
23- import java .lang .management .RuntimeMXBean ;
24- import java .util .LinkedHashMap ;
25- import java .util .Map ;
26-
27- import javax .ws .rs .GET ;
28- import javax .ws .rs .Path ;
29- import javax .ws .rs .Produces ;
30- import javax .ws .rs .core .MediaType ;
31-
3222import org .apache .ranger .metrics .RangerAdminMetricsWrapper ;
3323import org .apache .ranger .plugin .model .RangerMetrics ;
3424import org .apache .ranger .util .RangerMetricsUtil ;
4030import org .springframework .transaction .annotation .Propagation ;
4131import org .springframework .transaction .annotation .Transactional ;
4232
33+ import javax .ws .rs .GET ;
34+ import javax .ws .rs .Path ;
35+ import javax .ws .rs .Produces ;
36+ import javax .ws .rs .core .MediaType ;
37+
38+ import java .lang .management .ManagementFactory ;
39+ import java .lang .management .RuntimeMXBean ;
40+ import java .util .LinkedHashMap ;
41+ import java .util .Map ;
42+
4343@ Path ("metrics" )
4444@ Component
4545@ Scope ("request" )
4646@ Transactional (propagation = Propagation .REQUIRES_NEW )
4747public class MetricsREST {
4848 private static final Logger LOG = LoggerFactory .getLogger (MetricsREST .class );
49- private static final RuntimeMXBean RUNTIME = ManagementFactory .getRuntimeMXBean ();
50- private static final String JVM_MACHINE_ACTUAL_NAME = RUNTIME .getVmName ();
51- private static final String VERSION = RUNTIME .getVmVersion ();
52- private static final String JVM_MACHINE_REPRESENTATION_NAME = RUNTIME .getName ();
53- private static final String JVM_VENDOR_NAME = RUNTIME .getVmVendor ();
49+
50+ private static final RuntimeMXBean RUNTIME = ManagementFactory .getRuntimeMXBean ();
51+ private static final String JVM_MACHINE_ACTUAL_NAME = RUNTIME .getVmName ();
52+ private static final String VERSION = RUNTIME .getVmVersion ();
53+ private static final String JVM_MACHINE_REPRESENTATION_NAME = RUNTIME .getName ();
54+ private static final String JVM_VENDOR_NAME = RUNTIME .getVmVendor ();
5455
5556 @ Autowired
5657 RangerMetricsUtil jvmMetricUtil ;
@@ -60,25 +61,23 @@ public class MetricsREST {
6061
6162 @ GET
6263 @ Path ("/status" )
63- @ Produces ({ "application/json" } )
64+ @ Produces ("application/json" )
6465 public RangerMetrics getStatus () {
65- if (LOG .isDebugEnabled ()) {
66- LOG .debug ("==> MetricsREST.getStatus()" );
67- }
66+ LOG .debug ("==> MetricsREST.getStatus()" );
6867
69- Map <String , Object > jvm = new LinkedHashMap <>();
68+ Map <String , Object > jvm = new LinkedHashMap <>();
7069 Map <String , Object > vmDetails = new LinkedHashMap <>();
70+
7171 vmDetails .put ("JVM Machine Actual Name" , JVM_MACHINE_ACTUAL_NAME );
7272 vmDetails .put ("version" , VERSION );
7373 vmDetails .put ("JVM Machine Representation Name" , JVM_MACHINE_REPRESENTATION_NAME );
7474 vmDetails .put ("Up time of JVM" , RUNTIME .getUptime ());
7575 vmDetails .put ("JVM Vendor Name" , JVM_VENDOR_NAME );
7676 vmDetails .putAll (jvmMetricUtil .getValues ());
77- jvm .put ("jvm" ,vmDetails );
7877
79- if ( LOG . isDebugEnabled ()) {
80- LOG . debug ( "<== MetricsREST.getStatus(): jvm=" + jvm );
81- }
78+ jvm . put ( "jvm" , vmDetails );
79+
80+ LOG . debug ( "<== MetricsREST.getStatus(): jvm={}" , jvm );
8281
8382 return new RangerMetrics (jvm );
8483 }
@@ -87,40 +86,37 @@ public RangerMetrics getStatus() {
8786 @ Path ("/prometheus" )
8887 @ Produces (MediaType .TEXT_PLAIN )
8988 public String getMetricsPrometheus () {
90- if (LOG .isDebugEnabled ()) {
91- LOG .debug ("==> MetricsREST.getMetricsPrometheus()" );
92- }
89+ LOG .debug ("==> MetricsREST.getMetricsPrometheus()" );
90+
9391 String ret = "" ;
92+
9493 try {
9594 ret = rangerAdminMetricsWrapper .getRangerMetricsInPrometheusFormat ();
9695 } catch (Exception e ) {
9796 LOG .error ("MetricsREST.getMetricsPrometheus(): Exception occurred while getting metric." , e );
9897 }
9998
100- if (LOG .isDebugEnabled ()) {
101- LOG .debug ("<== MetricsREST.getMetricsPrometheus(): ret=" + ret );
102- }
99+ LOG .debug ("<== MetricsREST.getMetricsPrometheus(): ret={}" , ret );
100+
103101 return ret ;
104102 }
105103
106104 @ GET
107105 @ Path ("/json" )
108106 @ Produces (MediaType .APPLICATION_JSON )
109107 public Map <String , Map <String , Object >> getMetricsJson () {
110- if (LOG .isDebugEnabled ()) {
111- LOG .debug ("==> MetricsREST.getMetricsJson()" );
112- }
108+ LOG .debug ("==> MetricsREST.getMetricsJson()" );
113109
114110 Map <String , Map <String , Object >> ret = null ;
111+
115112 try {
116113 ret = rangerAdminMetricsWrapper .getRangerMetrics ();
117114 } catch (Exception e ) {
118115 LOG .error ("MetricsREST.getMetricsJson(): Exception occurred while getting metric." , e );
119116 }
120117
121- if (LOG .isDebugEnabled ()) {
122- LOG .debug ("<== MetricsREST.getMetricsJson(): ret=" + ret );
123- }
118+ LOG .debug ("<== MetricsREST.getMetricsJson(): ret={}" , ret );
119+
124120 return ret ;
125121 }
126122}
0 commit comments