本文整理汇总了Java中com.netflix.servo.DefaultMonitorRegistry类的典型用法代码示例。如果您正苦于以下问题:Java DefaultMonitorRegistry类的具体用法?Java DefaultMonitorRegistry怎么用?Java DefaultMonitorRegistry使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
DefaultMonitorRegistry类属于com.netflix.servo包,在下文中一共展示了DefaultMonitorRegistry类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: start
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
/**
* Start the plugin.
*/
public void start() {
if (!config.isEnabled()) {
LOGGER.info("Atlas Plugin is disabled.");
return;
}
final List<MetricPoller> pollers = Lists.newArrayList();
final MonitorRegistry registry = DefaultMonitorRegistry.getInstance();
final MetricPoller poller = new MonitorRegistryMetricPoller(registry);
pollers.add(poller);
final MetricPoller jvmPoller = new JvmMetricPoller();
pollers.add(jvmPoller);
thePoller = new CompositePoller(pollers);
final long delayForMainPoller = delaySecondsFor(Pollers.getPollingIntervals().get(0));
addPoller(thePoller, delayForMainPoller, TimeUnit.SECONDS);
registry.register(Monitors.newObjectMonitor(observer));
LOGGER.info("Starting to keep track of the cpu usage for threads in the jvm.");
ThreadCpuStats.getInstance().start();
LOGGER.info("Atlas Plugin started.");
}
开发者ID:dmuino,项目名称:atlas-oss-plugin,代码行数:27,代码来源:AtlasPlugin.java
示例2: getNumberGauge
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public static <T extends Number> T getNumberGauge(MonitorConfig config, T number) {
NumberGauge v = GAUGES.get(config);
if (v != null) {
return (T) v.getValue(0);
} else {
NumberGauge gauge = new NumberGauge(config, number);
NumberGauge prev = GAUGES.putIfAbsent(config, gauge);
if (prev != null) {
return (T) prev.getValue(0);
} else {
DefaultMonitorRegistry.getInstance().register(gauge);
return (T) gauge.getValue(0);
}
}
}
开发者ID:dmuino,项目名称:atlas-oss-plugin,代码行数:17,代码来源:Servo.java
示例3: getOrCreateCounter
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
private DynoOpCounter getOrCreateCounter(String opName, boolean compressionEnabled) {
String counterName = opName + "_" + compressionEnabled;
DynoOpCounter counter = counterMap.get(counterName);
if (counter != null) {
return counter;
}
counter = new DynoOpCounter(appName, counterName);
DynoOpCounter prevCounter = counterMap.putIfAbsent(counterName, counter);
if (prevCounter != null) {
return prevCounter;
}
DefaultMonitorRegistry.getInstance().register(counter.success);
DefaultMonitorRegistry.getInstance().register(counter.failure);
DefaultMonitorRegistry.getInstance().register(counter.successCompressionEnabled);
DefaultMonitorRegistry.getInstance().register(counter.failureCompressionEnabled);
return counter;
}
开发者ID:Netflix,项目名称:dyno,代码行数:24,代码来源:DynoOPMonitor.java
示例4: getOrCreateTimers
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
private DynoTimingCounters getOrCreateTimers(String opName) {
DynoTimingCounters timer = timerMap.get(opName);
if (timer != null) {
return timer;
}
timer = new DynoTimingCounters(appName, opName);
DynoTimingCounters prevTimer = timerMap.putIfAbsent(opName, timer);
if (prevTimer != null) {
return prevTimer;
}
DefaultMonitorRegistry.getInstance().register(timer.latMean);
DefaultMonitorRegistry.getInstance().register(timer.lat99);
DefaultMonitorRegistry.getInstance().register(timer.lat995);
DefaultMonitorRegistry.getInstance().register(timer.lat999);
return timer;
}
开发者ID:Netflix,项目名称:dyno,代码行数:18,代码来源:DynoOPMonitor.java
示例5: init
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public void init() {
// register the counters
DefaultMonitorRegistry.getInstance().register(pipelineSync);
DefaultMonitorRegistry.getInstance().register(pipelineDiscard);
// register the pipeline timer
DefaultMonitorRegistry.getInstance().register(timer.latMean);
DefaultMonitorRegistry.getInstance().register(timer.lat99);
DefaultMonitorRegistry.getInstance().register(timer.lat995);
DefaultMonitorRegistry.getInstance().register(timer.lat999);
// NOTE -- pipeline 'send' timers are created on demand and are registered
// in PipelineSendTimer.getOrCreateHistogram()
Logger.debug(String.format("Initializing DynoJedisPipelineMonitor with timing counter reset frequency %d",
resetTimingsFrequencyInSeconds));
if (resetTimingsFrequencyInSeconds > 0) {
threadPool.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
timer.reset();
sendTimer.reset();
}
}, 1, resetTimingsFrequencyInSeconds, TimeUnit.SECONDS);
}
}
开发者ID:Netflix,项目名称:dyno,代码行数:26,代码来源:DynoJedisPipelineMonitor.java
示例6: multiRegistration
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
@Test
public void multiRegistration() {
// Servo uses statics internally and the indended use of ServoRegistry
// is there would be one in use at a given time. We don't want to make
// it a singleton because that would break some existing unit tests that
// expect isolated counts from the spectator api. This test just verifies
// that multiple registrations can coexist in servo and will not clobber
// each other.
MonitorRegistry mr = DefaultMonitorRegistry.getInstance();
ServoRegistry r1 = new ServoRegistry();
Assert.assertTrue(mr.getRegisteredMonitors().contains(r1));
ServoRegistry r2 = new ServoRegistry();
Assert.assertTrue(mr.getRegisteredMonitors().contains(r1));
Assert.assertTrue(mr.getRegisteredMonitors().contains(r2));
ServoRegistry r3 = new ServoRegistry();
Assert.assertTrue(mr.getRegisteredMonitors().contains(r1));
Assert.assertTrue(mr.getRegisteredMonitors().contains(r2));
Assert.assertTrue(mr.getRegisteredMonitors().contains(r3));
}
开发者ID:Netflix,项目名称:spectator,代码行数:23,代码来源:ServoRegistryTest.java
示例7: getLongGauge
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public static LongGauge getLongGauge(String name) {
LongGauge gauge = (LongGauge) monitorMap.get(name);
if (gauge == null) {
writeLock.lock();
try {
if (monitorMap.containsKey(name)) {
gauge = (LongGauge) monitorMap.get(name);
} else {
gauge = new LongGauge(MonitorConfig.builder(name).withTag(OWNER).build());
monitorMap.put(name, gauge);
DefaultMonitorRegistry.getInstance().register(gauge);
}
} finally {
writeLock.unlock();
}
}
return gauge;
}
开发者ID:Netflix,项目名称:EVCache,代码行数:19,代码来源:EVCacheMetricsFactory.java
示例8: getStepCounter
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public static StepCounter getStepCounter(String appName, String cacheName, String metric) {
final String metricName = getMetricName(appName, null, metric);
final String name = new StringBuilder(128).append(metricName).append((cacheName == null ? "" : "-" + cacheName + "-")).append("type=StepCounter").toString();
final StepCounter counter = (StepCounter) monitorMap.get(name);
if (counter != null) return counter;
writeLock.lock();
try {
if (monitorMap.containsKey(name))
return (StepCounter) monitorMap.get(name);
else {
final StepCounter _counter = new StepCounter(getMonitorConfig(metricName, appName, cacheName, metric));
monitorMap.put(name, _counter);
DefaultMonitorRegistry.getInstance().register(_counter);
return _counter;
}
} finally {
writeLock.unlock();
}
}
开发者ID:Netflix,项目名称:EVCache,代码行数:21,代码来源:EVCacheMetricsFactory.java
示例9: getStatsTimer
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public static StatsTimer getStatsTimer(String appName, String cacheName, String metric) {
final String metricName = getMetricName(appName, null, metric);
final String name = new StringBuilder(128).append(metricName).append((cacheName == null ? "" : "-" + cacheName + "-")).append("type=StatsTimer").toString();
final StatsTimer duration = (StatsTimer) monitorMap.get(name);
if (duration != null) return duration;
writeLock.lock();
try {
if (monitorMap.containsKey(name))
return (StatsTimer) monitorMap.get(name);
else {
final StatsConfig statsConfig = new StatsConfig.Builder().withPercentiles(new double[] { 95, 99 })
.withPublishMax(true).withPublishMin(true)
.withPublishMean(true).withPublishCount(true).withSampleSize(sampleSize.get()).build();
final StatsTimer _duration = new StatsTimer(getMonitorConfig(metricName, appName, cacheName, metric),
statsConfig, TimeUnit.MILLISECONDS);
monitorMap.put(name, _duration);
DefaultMonitorRegistry.getInstance().register(_duration);
return _duration;
}
} finally {
writeLock.unlock();
}
}
开发者ID:Netflix,项目名称:EVCache,代码行数:25,代码来源:EVCacheMetricsFactory.java
示例10: initMetricsPublishing
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
/**
* Get the initial metrics and register with servo.
*/
public void initMetricsPublishing() {
/* list of monitors */
List<Monitor<?>> monitors = getMetricsMonitors();
MonitorConfig commandMetricsConfig = MonitorConfig.builder("metrics").build();
BasicCompositeMonitor commandMetricsMonitor = new BasicCompositeMonitor(commandMetricsConfig, monitors);
DefaultMonitorRegistry.getInstance().register(commandMetricsMonitor);
}
开发者ID:apache,项目名称:incubator-servicecomb-java-chassis,代码行数:11,代码来源:MetricsServoRegistry.java
示例11: getCounter
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public static Counter getCounter(MonitorConfig config) {
Counter v = COUNTERS.get(config);
if (v != null) {
return v;
} else {
Counter counter = new BasicCounter(config);
Counter prevCounter = COUNTERS.putIfAbsent(config, counter);
if (prevCounter != null) {
return prevCounter;
} else {
DefaultMonitorRegistry.getInstance().register(counter);
return counter;
}
}
}
开发者ID:dmuino,项目名称:atlas-oss-plugin,代码行数:16,代码来源:Servo.java
示例12: getTimer
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public static Timer getTimer(MonitorConfig config) {
Timer v = TIMERS.get(config);
if (v != null) {
return v;
} else {
Timer timer = new BasicTimer(config, TimeUnit.SECONDS);
Timer prevTimer = TIMERS.putIfAbsent(config, timer);
if (prevTimer != null) {
return prevTimer;
} else {
DefaultMonitorRegistry.getInstance().register(timer);
return timer;
}
}
}
开发者ID:dmuino,项目名称:atlas-oss-plugin,代码行数:16,代码来源:Servo.java
示例13: DynoCPMonitor
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public DynoCPMonitor(String namePrefix) {
try {
DefaultMonitorRegistry.getInstance().register(Monitors.newObjectMonitor(namePrefix, this));
} catch (Exception e) {
Logger.warn("Failed to register metrics with monitor registry", e);
}
}
开发者ID:Netflix,项目名称:dyno,代码行数:9,代码来源:DynoCPMonitor.java
示例14: getOrCreateCounter
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
private BasicCounter getOrCreateCounter(String opName) {
BasicCounter counter = counterMap.get(opName);
if (counter != null) {
return counter;
}
counter = getNewPipelineCounter(opName);
BasicCounter prevCounter = counterMap.putIfAbsent(opName, counter);
if (prevCounter != null) {
return prevCounter;
}
DefaultMonitorRegistry.getInstance().register(counter);
return counter;
}
开发者ID:Netflix,项目名称:dyno,代码行数:15,代码来源:DynoJedisPipelineMonitor.java
示例15: getOrCreateHistogram
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
private EstimatedHistogramMean getOrCreateHistogram(String opName) {
if (histograms.containsKey(opName)) {
return histograms.get(opName);
} else {
EstimatedHistogram histogram = new EstimatedHistogram();
EstimatedHistogramMean histogramMean =
new EstimatedHistogramMean("Dyno__" + appName + "__PL__latMean", "PL_SEND", opName, histogram);
histograms.put(opName, histogramMean);
DefaultMonitorRegistry.getInstance().register(histogramMean);
return histogramMean;
}
}
开发者ID:Netflix,项目名称:dyno,代码行数:13,代码来源:DynoJedisPipelineMonitor.java
示例16: getCounter
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public static Counter getCounter(MonitorConfig config) {
Counter v = counters.get(config);
if (v != null) return v;
else {
Counter counter = new BasicCounter(config);
Counter prevCounter = counters.putIfAbsent(config, counter);
if (prevCounter != null) return prevCounter;
else {
DefaultMonitorRegistry.getInstance().register(counter);
return counter;
}
}
}
开发者ID:Netflix,项目名称:suro,代码行数:14,代码来源:Servo.java
示例17: getTimer
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public static Timer getTimer(MonitorConfig config) {
Timer v = timers.get(config);
if (v != null) return v;
else {
Timer timer = new BasicTimer(config, TimeUnit.SECONDS);
Timer prevTimer = timers.putIfAbsent(config, timer);
if (prevTimer != null) return prevTimer;
else {
DefaultMonitorRegistry.getInstance().register(timer);
return timer;
}
}
}
开发者ID:Netflix,项目名称:suro,代码行数:14,代码来源:Servo.java
示例18: getLongGauge
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public static LongGauge getLongGauge(MonitorConfig config) {
LongGauge v = longGauges.get(config);
if (v != null) return v;
else {
LongGauge gauge = new LongGauge(config);
LongGauge prev = longGauges.putIfAbsent(config, gauge);
if (prev != null) return prev;
else {
DefaultMonitorRegistry.getInstance().register(gauge);
return gauge;
}
}
}
开发者ID:Netflix,项目名称:suro,代码行数:14,代码来源:Servo.java
示例19: getDoubleGauge
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public static DoubleGauge getDoubleGauge(MonitorConfig config) {
DoubleGauge v = doubleGauges.get(config);
if (v != null) return v;
else {
DoubleGauge gauge = new DoubleGauge(config);
DoubleGauge prev = doubleGauges.putIfAbsent(config, gauge);
if (prev != null) return prev;
else {
DefaultMonitorRegistry.getInstance().register(gauge);
return gauge;
}
}
}
开发者ID:Netflix,项目名称:suro,代码行数:14,代码来源:Servo.java
示例20: RabbitMqTransportClient
import com.netflix.servo.DefaultMonitorRegistry; //导入依赖的package包/类
public RabbitMqTransportClient(final Ref ref, final Connection connection) throws IOException {
this.channel = connection.createChannel();
this.sendCount = new BasicCounter(
MonitorConfig.builder("sendCount").withTag(
"transport",
ref.toString()).build());
this.sendFailureCount = new BasicCounter(
MonitorConfig.builder("sendFailureCount").withTag(
"transport",
ref.toString()).build());
this.transportRef = new RabbitMqTransportRef(ref);
DefaultMonitorRegistry.getInstance().register(this.sendCount);
DefaultMonitorRegistry.getInstance().register(this.sendFailureCount);
}
开发者ID:ngerakines,项目名称:elasticservices,代码行数:16,代码来源:RabbitMqTransportClient.java
注:本文中的com.netflix.servo.DefaultMonitorRegistry类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论