import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
/**
 * Create a new {@link MetricCopyExporter} instance.
 * @param reader the metric reader
 * @param writer the metric writer
 * @param prefix the name prefix
 */
public MetricCopyExporter(MetricReader reader, GaugeWriter writer, String prefix) {
	super(prefix);
	this.reader = reader;
	this.writer = writer;
	if (writer instanceof CounterWriter) {
		this.counter = (CounterWriter) writer;
	}
	else {
		this.counter = null;
	}
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
public MetricExportAutoConfiguration(MetricExportProperties properties,
		ObjectProvider<MetricsEndpointMetricReader> endpointReaderProvider,
		@ExportMetricReader ObjectProvider<List<MetricReader>> readersProvider,
		@ExportMetricWriter ObjectProvider<Map<String, GaugeWriter>> writersProvider,
		ObjectProvider<Map<String, Exporter>> exportersProvider) {
	this.properties = properties;
	this.endpointReader = endpointReaderProvider.getIfAvailable();
	this.readers = readersProvider.getIfAvailable();
	this.writers = writersProvider.getIfAvailable();
	this.exporters = exportersProvider.getIfAvailable();
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
@Bean
public MetricReaderPublicMetrics metricReaderPublicMetrics() {
	return new MetricReaderPublicMetrics(
			new CompositeMetricReader(this.metricReaders == null ? new MetricReader[0]
					: this.metricReaders
							.toArray(new MetricReader[this.metricReaders.size()])));
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
@Test
public void createServices() throws Exception {
	this.context = new AnnotationConfigApplicationContext(
			MetricRepositoryAutoConfiguration.class);
	GaugeService gaugeService = this.context.getBean(BufferGaugeService.class);
	assertThat(gaugeService).isNotNull();
	assertThat(this.context.getBean(BufferCounterService.class)).isNotNull();
	assertThat(this.context.getBean(PrefixMetricReader.class)).isNotNull();
	gaugeService.submit("foo", 2.7);
	MetricReader bean = this.context.getBean(MetricReader.class);
	assertThat(bean.findOne("gauge.foo").getValue()).isEqualTo(2.7);
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
@Test
public void exposesMetrics() {
	List<Metric<?>> metrics = new ArrayList<Metric<?>>();
	metrics.add(mock(Metric.class));
	metrics.add(mock(Metric.class));
	MetricReader reader = mock(MetricReader.class);
	given(reader.findAll()).willReturn(metrics);
	MetricReaderPublicMetrics publicMetrics = new MetricReaderPublicMetrics(reader);
	assertThat(publicMetrics.metrics()).isEqualTo(metrics);
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
@Test
public void createServices() throws Exception {
	this.context = new AnnotationConfigApplicationContext(
			MetricRepositoryAutoConfiguration.class);
	GaugeService gaugeService = this.context.getBean(BufferGaugeService.class);
	assertNotNull(gaugeService);
	assertNotNull(this.context.getBean(BufferCounterService.class));
	assertNotNull(this.context.getBean(PrefixMetricReader.class));
	gaugeService.submit("foo", 2.7);
	assertEquals(2.7,
			this.context.getBean(MetricReader.class).findOne("gauge.foo").getValue());
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
@Test
public void exposesMetrics() {
	List<Metric<?>> metrics = new ArrayList<Metric<?>>();
	metrics.add(mock(Metric.class));
	metrics.add(mock(Metric.class));
	MetricReader reader = mock(MetricReader.class);
	given(reader.findAll()).willReturn(metrics);
	MetricReaderPublicMetrics publicMetrics = new MetricReaderPublicMetrics(reader);
	assertEquals(metrics, publicMetrics.metrics());
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
public MetricsListener(GaugeService gaugeService, RichGaugeReader richGaugeReader,
		MetricReader metricReader, List<Exporter> exporters) {
	this.gaugeService = gaugeService;
	this.richGaugeReader = richGaugeReader;
	this.metricReader = metricReader;
	this.exporters = exporters;
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
private MetricReader globalMetricsForAggregation() {
    return new RedisMetricRepository(this.redisConnectionFactory,
            this.export.getRedis().getAggregatePrefix(), this.export.getRedis().getKey());
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
private MetricReader aggregatesMetricReader() {
    AggregateMetricReader repository = new AggregateMetricReader(globalMetricsForAggregation());
    return repository;
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
public AggregateMetricReader(MetricReader source) {
	this.source = source;
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
PatternMatchingIterable(MetricReader reader) {
	this.reader = reader;
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
public void setReader(MetricReader reader) {
	this.reader = reader;
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
public PublicMetricsAutoConfiguration(
		@ExportMetricReader ObjectProvider<List<MetricReader>> metricReadersProvider) {
	this.metricReaders = metricReadersProvider.getIfAvailable();
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
public MetricReaderPublicMetrics(MetricReader metricReader) {
	Assert.notNull(metricReader, "MetricReader must not be null");
	this.metricReader = metricReader;
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
private MetricReader globalMetricsForAggregation() {
	return new RedisMetricRepository(this.connectionFactory,
			this.export.getRedis().getAggregatePrefix(),
			this.export.getRedis().getKey());
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
private MetricReader aggregatesMetricReader() {
	AggregateMetricReader repository = new AggregateMetricReader(
			globalMetricsForAggregation());
	repository.setKeyPattern(this.export.getAggregate().getKeyPattern());
	return repository;
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
/**
 * Exports a metric reader
 * @return a metric reader
 */
@Bean
@ExportMetricReader
public MetricReader metricReader() {
	return new MetricRegistryMetricReader(sharedRegistry);
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
@Bean
public MetricReaderPublicMetrics metricReaderPublicMetrics() {
	return new MetricReaderPublicMetrics(new CompositeMetricReader(
			this.metricReaders.toArray(new MetricReader[0])));
}
 

import org.springframework.boot.actuate.metrics.reader.MetricReader; //导入依赖的package包/类
/**
 * Create a new {@link MetricCopyExporter} instance.
 * @param reader the metric reader
 * @param writer the metric writer
 */
public MetricCopyExporter(MetricReader reader, MetricWriter writer) {
	this(reader, writer, "");
}