import zipkin.collector.CollectorSampler; //导入依赖的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.CollectorSampler; //导入依赖的package包/类
@Before
public void setup() {
  store = new InMemoryStorage();
  metrics = new InMemoryCollectorMetrics();

  collector = new SQSCollector.Builder()
      .queueUrl(sqsRule.queueUrl())
      .parallelism(2)
      .waitTimeSeconds(1) // using short wait time to make test teardown faster
      .endpointConfiguration(new EndpointConfiguration(sqsRule.queueUrl(), "us-east-1"))
      .credentialsProvider(new AWSStaticCredentialsProvider(new BasicAWSCredentials("x", "x")))
      .metrics(metrics)
      .sampler(CollectorSampler.ALWAYS_SAMPLE)
      .storage(store)
      .build()
      .start();
}
 

import zipkin.collector.CollectorSampler; //导入依赖的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.CollectorSampler; //导入依赖的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.CollectorSampler; //导入依赖的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.CollectorSampler; //导入依赖的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.CollectorSampler; //导入依赖的package包/类
@Bean
CollectorSampler sampler() {
    return CollectorSampler.ALWAYS_SAMPLE;
}
 

import zipkin.collector.CollectorSampler; //导入依赖的package包/类
@Bean
CollectorSampler sampler() {
  return CollectorSampler.ALWAYS_SAMPLE;
}
 

import zipkin.collector.CollectorSampler; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(CollectorSampler.class)
CollectorSampler traceIdSampler(@Value("${zipkin.collector.sample-rate:1.0}") float rate) {
  return CollectorSampler.create(rate);
}
 

import zipkin.collector.CollectorSampler; //导入依赖的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.CollectorSampler; //导入依赖的package包/类
@Bean CollectorSampler sampler() {
  return CollectorSampler.ALWAYS_SAMPLE;
}
 

import zipkin.collector.CollectorSampler; //导入依赖的package包/类
@Override
public Builder sampler(CollectorSampler collectorSampler) {
  delegate.sampler(collectorSampler);
  return this;
}
 

import zipkin.collector.CollectorSampler; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean({CollectorSampler.class})
CollectorSampler traceIdSampler(@Value("${zipkin.collector.sample-rate:1.0}") float rate) {
	return CollectorSampler.create(rate);
}