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.");
}
 

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);
        }
    }
}
 

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; 
	}
 

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; 
}
 

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);
	}
}
 

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));
}
 

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;
}
 

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();
    }

}
 

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();
    }
}
 

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);
}
 

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;
        }
    }
}
 

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;
        }
    }
}
 

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);
	}
}
 

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; 
}
 

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;
        }
    }
 

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;
        }
    }
}
 

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;
        }
    }
}
 

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;
        }
    }
}
 

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;
        }
    }
}
 

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);
}