import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
@Bean
EventHubCollector eventHubCollector(EventHubCollectorProperties properties,
                                    CollectorSampler sampler,
                                    CollectorMetrics metrics,
                                    StorageComponent storage) {


  logger.log(Level.INFO,"===========EventHubCollectorAutoConfiguration==============");

  return properties.toBuilder()
      .sampler(sampler)
      .storage(storage)
      .metrics(metrics)
      .build()
      .start();
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
@Bean
EventHubCollector eventHubCollector(ZipkinEventHubCollectorProperties properties,
    CollectorSampler sampler,
    CollectorMetrics metrics,
    StorageComponent storage) {

  return properties.toBuilder()
      .sampler(sampler)
      .storage(storage)
      .metrics(metrics)
      .build()
      .start();
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
@Before
public void start() {
  scribe = ScribeCollector.builder()
      .metrics(CollectorMetrics.NOOP_METRICS)
      .storage(storage).build();
  scribe.start();
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
@Bean
SQSCollector sqsCollector(ZipkinSQSCollectorProperties properties, AWSCredentialsProvider credentialsProvider,
    CollectorSampler sampler, CollectorMetrics metrics, StorageComponent storage) {
  return properties.toBuilder()
      .queueUrl(properties.getQueueUrl())
      .waitTimeSeconds(properties.getWaitTimeSeconds())
      .parallelism(properties.getParallelism())
      .endpointConfiguration(endpointConfiguration)
      .credentialsProvider(credentialsProvider)
      .sampler(sampler)
      .metrics(metrics)
      .storage(storage)
      .build()
      .start();
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
@Bean
KinesisCollector kinesisCollector(ZipkinKinesisCollectorProperties properties,
    AWSCredentialsProvider credentialsProvider,
    CollectorSampler sampler, CollectorMetrics metrics, StorageComponent storage) {
  return KinesisCollector.builder()
      .credentialsProvider(credentialsProvider)
      .sampler(sampler)
      .metrics(metrics)
      .storage(storage)
      .streamName(properties.getStreamName())
      .appName(properties.getAppName())
      .build()
      .start();
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
/** lazy so transient storage errors don't crash bootstrap */
@Lazy
@Autowired
ZipkinMessageListener(StorageComponent storage, CollectorSampler sampler,
		CollectorMetrics metrics) {
	this.collector = Collector.builder(getClass())
			.storage(storage)
			.sampler(sampler)
			.metrics(metrics.forTransport("stream")).build();
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
@Bean
CollectorMetrics metrics() {
    return CollectorMetrics.NOOP_METRICS;
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
@Bean
CollectorMetrics metrics() {
  return CollectorMetrics.NOOP_METRICS;
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(CollectorMetrics.class)
CollectorMetrics metrics(CounterService counterService, GaugeService gaugeService) {
  return new ActuateCollectorMetrics(counterService, gaugeService);
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
@Autowired ZipkinHttpCollector(StorageComponent storage, CollectorSampler sampler,
    CollectorMetrics metrics) {
  this.metrics = metrics.forTransport("http");
  this.collector = Collector.builder(getClass())
      .storage(storage).sampler(sampler).metrics(this.metrics).build();
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
@Bean CollectorMetrics metrics() {
  return CollectorMetrics.NOOP_METRICS;
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
KafkaStreamProcessor(
    KafkaStream<byte[], byte[]> stream, Collector collector, CollectorMetrics metrics) {
  this.stream = stream;
  this.collector = collector;
  this.metrics = metrics;
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
ZipkinDispatcher(StorageComponent storage, CollectorMetrics metrics, MockWebServer server) {
  this.store = storage.spanStore();
  this.consumer = Collector.builder(getClass()).storage(storage).metrics(metrics).build();
  this.metrics = metrics;
  this.server = server;
}
 

import zipkin.collector.CollectorMetrics; //导入依赖的package包/类
@Bean
CollectorMetrics metrics() {
	return CollectorMetrics.NOOP_METRICS;
}