public CloudWatchReporter build() {
if (withJvmMetrics) {
metricRegistry.register("jvm.uptime", (Gauge<Long>) () -> ManagementFactory.getRuntimeMXBean().getUptime());
metricRegistry.register("jvm.current_time", (Gauge<Long>) clock::getTime);
metricRegistry.register("jvm.classes", new ClassLoadingGaugeSet());
metricRegistry.register("jvm.fd_usage", new FileDescriptorRatioGauge());
metricRegistry.register("jvm.buffers", new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
metricRegistry.register("jvm.gc", new GarbageCollectorMetricSet());
metricRegistry.register("jvm.memory", new MemoryUsageGaugeSet());
metricRegistry.register("jvm.thread-states", new ThreadStatesGaugeSet());
}
cwRateUnit = toStandardUnit(rateUnit);
cwDurationUnit = toStandardUnit(durationUnit);
return new CloudWatchReporter(this);
}
java类com.codahale.metrics.jvm.FileDescriptorRatioGauge的实例源码
CloudWatchReporter.java 文件源码
项目:codahale-aggregated-metrics-cloudwatch-reporter
阅读 34
收藏 0
点赞 0
评论 0
MetricsFactory.java 文件源码
项目:it-keeps
阅读 40
收藏 0
点赞 0
评论 0
public static void enableJvm() {
if (bEnableJvm)
return;
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_MEMORY, new MemoryUsageGaugeSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_GARBAGE, new GarbageCollectorMetricSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_THREADS, new ThreadStatesGaugeSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_FILES, new FileDescriptorRatioGauge());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_BUFFERS,
new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
final JmxReporter jmxReporter = JmxReporter.forRegistry(METRIC_REGISTRY).build();
jmxReporter.start();
bEnableJvm = true;
}
MetricsConfiguration.java 文件源码
项目:metadatamanagement
阅读 39
收藏 0
点赞 0
评论 0
@Override
public void onStartup(ServletContext servletContext) throws ServletException {
metricRegistry.register(PROP_METRIC_REG_JVM_MEMORY, new MemoryUsageGaugeSet());
metricRegistry.register(PROP_METRIC_REG_JVM_GARBAGE, new GarbageCollectorMetricSet());
metricRegistry.register(PROP_METRIC_REG_JVM_THREADS, new ThreadStatesGaugeSet());
metricRegistry.register(PROP_METRIC_REG_JVM_FILES, new FileDescriptorRatioGauge());
metricRegistry.register(PROP_METRIC_REG_JVM_BUFFERS,
new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
servletContext.setAttribute(InstrumentedFilter.REGISTRY_ATTRIBUTE, metricRegistry);
FilterRegistration.Dynamic metricsFilter =
servletContext.addFilter("webappMetricsFilter", new InstrumentedFilter());
metricsFilter.addMappingForUrlPatterns(
EnumSet.of(DispatcherType.REQUEST, DispatcherType.FORWARD, DispatcherType.ASYNC), true,
"/*");
metricsFilter.setAsyncSupported(true);
}
TajoSystemMetrics.java 文件源码
项目:tajo
阅读 29
收藏 0
点赞 0
评论 0
public void start() {
setMetricsReporter(metricsGroupName);
final String jvmMetricsName = metricsGroupName + "-JVM";
setMetricsReporter(jvmMetricsName);
if(!inited) {
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "MEMORY"), new MemoryUsageGaugeSet());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "FILE"), new FileDescriptorRatioGauge());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "GC"), new GarbageCollectorMetricSet());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "THREAD"), new ThreadStatesGaugeSet());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "LOG"), new LogEventGaugeSet());
jmxReporter = JmxReporter.forRegistry(metricRegistry).inDomain("Tajo")
.createsObjectNamesWith(new TajoJMXObjectNameFactory()).build();
jmxReporter.start();
}
inited = true;
}
OneOpsMetrics.java 文件源码
项目:oneops
阅读 28
收藏 0
点赞 0
评论 0
/**
* Add metrics JVM gauges.
*/
private void addJvmMetrics() {
if (getB("jvm.gcstats", false)) {
ooMetricsRegistry.registerAll(new GarbageCollectorMetricSet());
}
if (getB("jvm.memory", false)) {
ooMetricsRegistry.registerAll(new MemoryUsageGaugeSet());
}
if (getB("jvm.threadstate", false)) {
ooMetricsRegistry.registerAll(new ThreadStatesGaugeSet());
}
if (getB("jvm.filedescriptor", false)) {
ooMetricsRegistry.register("openfd.ratio", new FileDescriptorRatioGauge());
}
}
MonitoringModule.java 文件源码
项目:curiostack
阅读 30
收藏 0
点赞 0
评论 0
private static void configureJvmMetrics(MetricRegistry registry) {
MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
registry.register("jvm.buffer-pool", new BufferPoolMetricSet(mBeanServer));
registry.register("jvm.class-loading", new ClassLoadingGaugeSet());
registry.register("jvm.file-descriptor-ratio", new FileDescriptorRatioGauge());
registry.register("jvm.gc", new GarbageCollectorMetricSet());
registry.register("jvm.memory", new MemoryUsageGaugeSet());
registry.register("jvm.threads", new ThreadStatesGaugeSet());
}
MetricsConfiguration.java 文件源码
项目:BCDS
阅读 35
收藏 0
点赞 0
评论 0
@PostConstruct
public void init() {
log.debug("Registering JVM gauges");
metricRegistry.register(PROP_METRIC_REG_JVM_MEMORY, new MemoryUsageGaugeSet());
metricRegistry.register(PROP_METRIC_REG_JVM_GARBAGE, new GarbageCollectorMetricSet());
metricRegistry.register(PROP_METRIC_REG_JVM_THREADS, new ThreadStatesGaugeSet());
metricRegistry.register(PROP_METRIC_REG_JVM_FILES, new FileDescriptorRatioGauge());
metricRegistry.register(PROP_METRIC_REG_JVM_BUFFERS, new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
if (propertyResolver.getProperty(PROP_JMX_ENABLED, Boolean.class, false)) {
log.info("Initializing Metrics JMX reporting");
JmxReporter jmxReporter = JmxReporter.forRegistry(metricRegistry).build();
jmxReporter.start();
}
}
MetricsConfiguration.java 文件源码
项目:ehcache3-samples
阅读 32
收藏 0
点赞 0
评论 0
@PostConstruct
public void init() {
log.debug("Registering JVM gauges");
metricRegistry.register(PROP_METRIC_REG_JVM_MEMORY, new MemoryUsageGaugeSet());
metricRegistry.register(PROP_METRIC_REG_JCACHE_STATISTICS, new JCacheGaugeSet());
metricRegistry.register(PROP_METRIC_REG_JVM_GARBAGE, new GarbageCollectorMetricSet());
metricRegistry.register(PROP_METRIC_REG_JVM_THREADS, new ThreadStatesGaugeSet());
metricRegistry.register(PROP_METRIC_REG_JVM_FILES, new FileDescriptorRatioGauge());
metricRegistry.register(PROP_METRIC_REG_JVM_BUFFERS, new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
if (hikariDataSource != null) {
log.debug("Monitoring the datasource");
hikariDataSource.setMetricRegistry(metricRegistry);
}
if (jHipsterProperties.getMetrics().getJmx().isEnabled()) {
log.debug("Initializing Metrics JMX reporting");
JmxReporter jmxReporter = JmxReporter.forRegistry(metricRegistry).build();
jmxReporter.start();
}
if (jHipsterProperties.getMetrics().getLogs().isEnabled()) {
log.info("Initializing Metrics Log reporting");
final Slf4jReporter reporter = Slf4jReporter.forRegistry(metricRegistry)
.outputTo(LoggerFactory.getLogger("metrics"))
.convertRatesTo(TimeUnit.SECONDS)
.convertDurationsTo(TimeUnit.MILLISECONDS)
.build();
reporter.start(jHipsterProperties.getMetrics().getLogs().getReportFrequency(), TimeUnit.SECONDS);
}
}
MeterConfiguration.java 文件源码
项目:haven-platform
阅读 76
收藏 0
点赞 0
评论 0
@Override
public void configureReporters(MetricRegistry metricRegistry) {
metricRegistry.addListener(metricsListener);
metricRegistry.register("jvm.gc", new GarbageCollectorMetricSet());
metricRegistry.register("jvm.memory", new MemoryUsageGaugeSet());
metricRegistry.register("jvm.thread-states", new ThreadStatesGaugeSet());
metricRegistry.register("jvm.fd.usage", new FileDescriptorRatioGauge());
if(environment.acceptsProfiles(AmqpUtils.PROFILE)) {
final String applicationId = AppInfo.getApplicationName();
AmqpUtils.ExchangeFactory exchangeFactory = new AmqpUtils.ExchangeFactory();
exchangeFactory.setExchangeName(exchange);
AmqpReporter amqpReporter = AmqpReporter.forRegistry(metricRegistry)
.connectionFactoryProvider(connectionFactoryProvider)
.exchangeName(exchange)
.routingKey(applicationId)
.exchangeFactory(exchangeFactory)
.build();
amqpReporter.start(reportPeriod, TimeUnit.SECONDS);
LOG.info("AmqpReporter enabled: applicationId: {} reportPeriod: {} seconds, exchange: {}",
applicationId, reportPeriod, exchange);
} else {
//sample configuration for metrics reported
// https://dropwizard.github.io/metrics/3.1.0/manual/core/#man-core-reporters-console
final Slf4jReporter reporter = Slf4jReporter.forRegistry(metricRegistry)
.outputTo(LoggerFactory.getLogger("com.codeabovelab.dm.metrics"))
.convertRatesTo(TimeUnit.SECONDS)
.convertDurationsTo(TimeUnit.MILLISECONDS)
.build();
reporter.start(reportPeriod, TimeUnit.SECONDS);
}
}
DrillMetrics.java 文件源码
项目:drill
阅读 30
收藏 0
点赞 0
评论 0
private static void registerSystemMetrics() {
REGISTRY.registerAll(new GarbageCollectorMetricSet());
REGISTRY.registerAll(new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
REGISTRY.registerAll(new MemoryUsageGaugeSet());
REGISTRY.registerAll(new ThreadStatesGaugeSet());
register("fd.usage", new FileDescriptorRatioGauge());
}
MetricsServlet.java 文件源码
项目:nexus-public
阅读 33
收藏 0
点赞 0
评论 0
@Inject
public MetricsServlet(final MetricRegistry registry) {
super(registry);
// JVM metrics are no longer automatically added in codahale-metrics
registry.register(name("jvm", "vm"), new JvmAttributeGaugeSet());
registry.register(name("jvm", "memory"), new MemoryUsageGaugeSet());
registry.register(name("jvm", "buffers"), new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
registry.register(name("jvm", "fd_usage"), new FileDescriptorRatioGauge());
registry.register(name("jvm", "thread-states"), new ThreadStatesGaugeSet());
registry.register(name("jvm", "garbage-collectors"), new GarbageCollectorMetricSet());
}
MetricsConfiguration.java 文件源码
项目:lobbycal
阅读 36
收藏 0
点赞 0
评论 0
@PostConstruct
public void init() {
log.debug("Registering JVM gauges");
metricRegistry.register(PROP_METRIC_REG_JVM_MEMORY, new MemoryUsageGaugeSet());
metricRegistry.register(PROP_METRIC_REG_JVM_GARBAGE, new GarbageCollectorMetricSet());
metricRegistry.register(PROP_METRIC_REG_JVM_THREADS, new ThreadStatesGaugeSet());
metricRegistry.register(PROP_METRIC_REG_JVM_FILES, new FileDescriptorRatioGauge());
metricRegistry.register(PROP_METRIC_REG_JVM_BUFFERS, new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
if (jHipsterProperties.getMetrics().getJmx().isEnabled()) {
log.debug("Initializing Metrics JMX reporting");
JmxReporter jmxReporter = JmxReporter.forRegistry(metricRegistry).build();
jmxReporter.start();
}
}
MetricsModule.java 文件源码
项目:datacollector
阅读 29
收藏 0
点赞 0
评论 0
@Provides @Singleton MetricRegistry provideMetrics() {
MetricRegistry metrics = new MetricRegistry();
metrics.register("jvm.memory", new MemoryUsageGaugeSet());
metrics.register("jvm.garbage", new GarbageCollectorMetricSet());
metrics.register("jvm.threads", new ThreadStatesGaugeSet());
metrics.register("jvm.files", new FileDescriptorRatioGauge());
metrics.register("jvm.buffers", new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
return metrics;
}
MetricsConfiguration.java 文件源码
项目:p2p-webtv
阅读 37
收藏 0
点赞 0
评论 0
@PostConstruct
public void init() {
log.debug("Registering JVM gauges");
metricRegistry.register(PROP_METRIC_REG_JVM_MEMORY, new MemoryUsageGaugeSet());
metricRegistry.register(PROP_METRIC_REG_JVM_GARBAGE, new GarbageCollectorMetricSet());
metricRegistry.register(PROP_METRIC_REG_JVM_THREADS, new ThreadStatesGaugeSet());
metricRegistry.register(PROP_METRIC_REG_JVM_FILES, new FileDescriptorRatioGauge());
metricRegistry.register(PROP_METRIC_REG_JVM_BUFFERS, new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
if (applicationProperties.getMetrics().getJmx().isEnabled()) {
log.debug("Initializing Metrics JMX reporting");
JmxReporter jmxReporter = JmxReporter.forRegistry(metricRegistry).build();
jmxReporter.start();
}
}
MetricsConfiguration.java 文件源码
项目:agate
阅读 29
收藏 0
点赞 0
评论 0
@PostConstruct
public void init() {
log.debug("Registering JVM gauges");
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_MEMORY, new MemoryUsageGaugeSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_GARBAGE, new GarbageCollectorMetricSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_THREADS, new ThreadStatesGaugeSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_FILES, new FileDescriptorRatioGauge());
METRIC_REGISTRY
.register(PROP_METRIC_REG_JVM_BUFFERS, new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
if(propertyResolver.getProperty(PROP_JMX_ENABLED, Boolean.class, false)) {
log.info("Initializing Metrics JMX reporting");
JmxReporter jmxReporter = JmxReporter.forRegistry(METRIC_REGISTRY).build();
jmxReporter.start();
}
}
MetricRegistryInitializer.java 文件源码
项目:modules
阅读 33
收藏 0
点赞 0
评论 0
/**
* Registers a default set of metrics for the JVM.
*/
private void registerDefaultMetrics() {
metricRegistry.register(JVM_GARBAGE_COLLECTOR_METRICS, new GarbageCollectorMetricSet());
metricRegistry.register(JVM_MEMORY_METRICS, new MemoryUsageGaugeSet());
metricRegistry.register(JVM_THREAD_METRICS, new ThreadStatesGaugeSet());
metricRegistry.register(JVM_FILE_DESCRIPTOR_METRICS, new FileDescriptorRatioGauge());
}
TajoSystemMetrics.java 文件源码
项目:incubator-tajo
阅读 29
收藏 0
点赞 0
评论 0
public void start() {
setMetricsReporter(metricsGroupName);
String jvmMetricsName = metricsGroupName + "-jvm";
setMetricsReporter(jvmMetricsName);
if(!inited) {
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "Heap"), new MemoryUsageGaugeSet());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "File"), new FileDescriptorRatioGauge());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "GC"), new GarbageCollectorMetricSet());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "Thread"), new ThreadStatesGaugeSet());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "Log"), new LogEventGaugeSet());
}
inited = true;
}
TajoSystemMetrics.java 文件源码
项目:tajo-cdh
阅读 32
收藏 0
点赞 0
评论 0
public void start() {
setMetricsReporter(metricsGroupName);
String jvmMetricsName = metricsGroupName + "-jvm";
setMetricsReporter(jvmMetricsName);
if(!inited) {
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "Heap"), new MemoryUsageGaugeSet());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "File"), new FileDescriptorRatioGauge());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "GC"), new GarbageCollectorMetricSet());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "Thread"), new ThreadStatesGaugeSet());
metricRegistry.register(MetricRegistry.name(jvmMetricsName, "Log"), new LogEventGaugeSet());
}
inited = true;
}
JMXReportingService.java 文件源码
项目:incubator-gobblin
阅读 21
收藏 0
点赞 0
评论 0
private void registerJvmMetrics() {
registerMetricSetWithPrefix("jvm.gc", new GarbageCollectorMetricSet());
registerMetricSetWithPrefix("jvm.memory", new MemoryUsageGaugeSet());
registerMetricSetWithPrefix("jvm.threads", new ThreadStatesGaugeSet());
this.metricRegistry.register("jvm.fileDescriptorRatio", new FileDescriptorRatioGauge());
for (Map.Entry<String, MetricSet> metricSet : this.additionalMetricSets.entrySet()) {
registerMetricSetWithPrefix(metricSet.getKey(), metricSet.getValue());
}
}
MetricsConfiguration.java 文件源码
项目:chassis
阅读 40
收藏 0
点赞 0
评论 0
/***
* Initializes the metrics registry
*
* @return metric registry bean
*/
@Bean
public MetricRegistry metricRegistry() {
final MetricRegistry bean = new MetricRegistry();
// add JVM metrics
bean.register("jvm.gc", new GarbageCollectorMetricSet());
bean.register("jvm.memory", new MemoryUsageGaugeSet());
bean.register("jvm.thread-states", new ThreadStatesGaugeSet());
bean.register("jvm.fd", new FileDescriptorRatioGauge());
return bean;
}
ChassisConfiguration.java 文件源码
项目:chassis
阅读 28
收藏 0
点赞 0
评论 0
/**
* Initializes the metrics registry
*
* @return metric registry bean
*/
@Bean
public MetricRegistry metricRegistry() {
final MetricRegistry bean = new MetricRegistry();
// add JVM metrics
bean.register("jvm.gc", new GarbageCollectorMetricSet());
bean.register("jvm.memory", new MemoryUsageGaugeSet());
bean.register("jvm.thread-states", new ThreadStatesGaugeSet());
bean.register("jvm.fd", new FileDescriptorRatioGauge());
bean.register("jvm.load-average", new Gauge<Double>() {
private OperatingSystemMXBean mxBean = ManagementFactory.getOperatingSystemMXBean();
public Double getValue() {
try {
return mxBean.getSystemLoadAverage();
} catch (Exception e) {
// not supported
return -1d;
}
}
});
// add Logback metrics
final LoggerContext factory = (LoggerContext) LoggerFactory.getILoggerFactory();
final Logger root = factory.getLogger(Logger.ROOT_LOGGER_NAME);
final InstrumentedAppender appender = new InstrumentedAppender(bean);
appender.setContext(root.getLoggerContext());
appender.start();
root.addAppender(appender);
return bean;
}
MetricsConfiguration.java 文件源码
项目:MLDS
阅读 33
收藏 0
点赞 0
评论 0
@PostConstruct
public void init() {
logger.debug("Registring JVM gauges");
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_MEMORY, new MemoryUsageGaugeSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_GARBAGE, new GarbageCollectorMetricSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_THREADS, new ThreadStatesGaugeSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_FILES, new FileDescriptorRatioGauge());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_BUFFERS, new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
if (propertyResolver.getProperty(PROP_JMX_ENABLED, Boolean.class, false)) {
logger.info("Initializing Metrics JMX reporting");
final JmxReporter jmxReporter = JmxReporter.forRegistry(METRIC_REGISTRY).build();
jmxReporter.start();
}
}
MetricsConfiguration.java 文件源码
项目:mica2
阅读 34
收藏 0
点赞 0
评论 0
@PostConstruct
public void init() {
log.debug("Registering JVM gauges");
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_MEMORY, new MemoryUsageGaugeSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_GARBAGE, new GarbageCollectorMetricSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_THREADS, new ThreadStatesGaugeSet());
METRIC_REGISTRY.register(PROP_METRIC_REG_JVM_FILES, new FileDescriptorRatioGauge());
METRIC_REGISTRY
.register(PROP_METRIC_REG_JVM_BUFFERS, new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer()));
if(propertyResolver.getProperty(PROP_JMX_ENABLED, Boolean.class, false)) {
log.info("Initializing Metrics JMX reporting");
JmxReporter jmxReporter = JmxReporter.forRegistry(METRIC_REGISTRY).build();
jmxReporter.start();
}
}
SiddhiStreamReporterTest.java 文件源码
项目:Decision
阅读 22
收藏 0
点赞 0
评论 0
@Test
public void testReport() throws Exception {
Clock clock= Clock.defaultClock();
reporter= builder.convertRatesTo(TimeUnit.MINUTES)
.convertDurationsTo(TimeUnit.SECONDS)
.withClock(clock)
.filter(MetricFilter.ALL)
.build();
reporter.start(1, TimeUnit.SECONDS);
SortedMap<String, Gauge> gauges= new TreeMap<>();
SortedMap<String, Counter> counters= new TreeMap<>();
SortedMap<String, Histogram> histograms= new TreeMap<>();
SortedMap<String, Meter> meters= new TreeMap<>();
SortedMap<String, Timer> timers= new TreeMap<>();
Gauge gauge= new FileDescriptorRatioGauge();
gauges.put("gauges", gauge);
Counter counter= new Counter();
counters.put("counters", counter);
Meter meter= new Meter();
meters.put("meters", meter);
Timer timer= new Timer();
timers.put("timers", timer);
Exception ex= null;
try {
reporter.report(gauges, counters, histograms, meters, timers);
} catch (Exception e) {ex= e; }
assertNull("Expected null value that means not exception", ex);
}
JvmMetrics.java 文件源码
项目:sling-metrics
阅读 39
收藏 0
点赞 0
评论 0
@Activate
protected void activate(final ComponentContext context) {
isEnabled = (Boolean) context.getProperties().get(JVM_METRICS_ENABLED);
if(metricService.isEnabled() && isEnabled) {
metricService.register(GARBAGE_COLLECTION_METRIC_NAME, new GarbageCollectorMetricSet());
metricService.register(MEMORY_METRIC_NAME, new MemoryUsageGaugeSet());
metricService.register(THREAD_STATES_METRIC_NAME, new ThreadStatesGaugeSet());
metricService.register(FILE_DESCRIPTORS_USAGE_METRIC_NAME, new FileDescriptorRatioGauge());
}
}
MetricsMain.java 文件源码
项目:haogrgr-test
阅读 25
收藏 0
点赞 0
评论 0
public static void main(String args[]) {
startReport();
Meter requests = metrics.meter("requests");
metrics.register("jvm.gc", new GarbageCollectorMetricSet());
metrics.register("jvm.fd", new FileDescriptorRatioGauge());
metrics.register("jvm.mm", new MemoryUsageGaugeSet());
metrics.register("jvm.tt", new ThreadStatesGaugeSet());
for (int i = 0; i < 1000; i++) {
requests.mark();
waitRandSeconds();
}
}
CoreMetricsModule.java 文件源码
项目:stdlib
阅读 24
收藏 0
点赞 0
评论 0
public static MetricRegistry buildRegistry()
{
MetricRegistry registry = new MetricRegistry();
registry.register(MetricRegistry.name("jvm", "gc"), new GarbageCollectorMetricSet());
registry.register(MetricRegistry.name("jvm", "memory"), new MemoryUsageGaugeSet());
registry.register(MetricRegistry.name("jvm", "thread-states"), new ThreadStatesGaugeSet());
registry.register(MetricRegistry.name("jvm", "fd", "usage"), new FileDescriptorRatioGauge());
return registry;
}
RegisterJVMMetricsBuilder.java 文件源码
项目:cdk
阅读 32
收藏 0
点赞 0
评论 0
public RegisterJVMMetrics(CommandBuilder builder, Config config, Command parent,
Command child, final MorphlineContext context) {
super(builder, config, parent, child, context);
validateArguments();
MetricRegistry registry = context.getMetricRegistry();
BufferPoolMetricSet bufferPoolMetrics = new BufferPoolMetricSet(ManagementFactory.getPlatformMBeanServer());
registerAll("jvm.buffers", bufferPoolMetrics, registry);
registerAll("jvm.gc", new GarbageCollectorMetricSet(), registry);
registerAll("jvm.memory", new MemoryUsageGaugeSet(), registry);
registerAll("jvm.threads", new ThreadStatesGaugeSet(), registry);
register("jvm.fileDescriptorCountRatio", new FileDescriptorRatioGauge(), registry);
context.getHealthCheckRegistry().register("deadlocks", new ThreadDeadlockHealthCheck());
}
FileDescriptorGaugeSet.java 文件源码
项目:semantic-metrics
阅读 20
收藏 0
点赞 0
评论 0
public FileDescriptorGaugeSet() {
fileDescriptorRatioGauge = new FileDescriptorRatioGauge();
}
SchedulerDaemon.java 文件源码
项目:Gobblin
阅读 31
收藏 0
点赞 0
评论 0
private void registerJvmMetrics() {
registerMetricSetWithPrefix("jvm.gc", new GarbageCollectorMetricSet());
registerMetricSetWithPrefix("jvm.memory", new MemoryUsageGaugeSet());
registerMetricSetWithPrefix("jvm.threads", new ThreadStatesGaugeSet());
this.metricRegistry.register("jvm.fileDescriptorRatio", new FileDescriptorRatioGauge());
}