import com.github.kristofa.brave.SpanCollector; //导入依赖的package包/类
private static Brave.Builder applySpanCollector(final Brave.Builder builder, final JsonObject json) {
  SpanCollector spanCollector;
  switch (json.getString("type")) {
    case "logging":
      spanCollector = new LoggingSpanCollector();
      break;
    case "scribe":
      spanCollector = ScribeSpanCollectorBuilder.build(json);
      break;
    case "kafka":
      spanCollector = KafkaSpanCollectorBuilder.build(json);
      break;
    case "empty":
    default:
      spanCollector = new EmptySpanCollector();
  }
  logger.debug("Configuring span collector: {}", spanCollector);
  return builder.spanCollector(spanCollector);
}
 

import com.github.kristofa.brave.SpanCollector; //导入依赖的package包/类
@Bean
public SpanCollector spanCollector() {
  HttpSpanCollector.Config config =
      HttpSpanCollector.Config.builder()
          .connectTimeout(properties.getConnectTimeout())
          .readTimeout(properties.getReadTimeout())
          .compressionEnabled(properties.isCompressionEnabled())
          .flushInterval(properties.getFlushInterval())
          .build();
  return HttpSpanCollector.create(
      properties.getUrl(), config, new EmptySpanCollectorMetricsHandler());
}
 

import com.github.kristofa.brave.SpanCollector; //导入依赖的package包/类
TracedSession(Session target, Brave brave, SpanCollector collector) {
  this.target = checkNotNull(target, "target");
  this.brave = checkNotNull(brave, "brave");
  this.collector = checkNotNull(collector, "collector");
  this.version = target.getCluster().getConfiguration().getProtocolOptions().getProtocolVersion();
  target.getCluster().register(this);
}
 

import com.github.kristofa.brave.SpanCollector; //导入依赖的package包/类
public static SpanCollector build(final JsonObject json) {
  KafkaSpanCollector.Config.Builder conf = KafkaSpanCollector.Config.builder(json.getString("bootstrapServers", "localhost"))
      .flushInterval(json.getInteger("flushInterval", 1))
      .topic(json.getString("topic", "zipkin"));

  return KafkaSpanCollector.create(conf.build(), new EmptySpanCollectorMetricsHandler());
}
 

import com.github.kristofa.brave.SpanCollector; //导入依赖的package包/类
@Bean
@Scope(value = "singleton")
public SpanCollector spanCollector() {

    // For development purposes we use the logging span collector.
    return new LoggingSpanCollectorImpl();
	//return new ZipkinSpanCollector("localhost", 9410);
}
 

import com.github.kristofa.brave.SpanCollector; //导入依赖的package包/类
public static Session create(Session target, Brave brave, SpanCollector collector) {
  return Reflection.newProxy(Session.class, new TracedSession(target, brave, collector));
}
 

import com.github.kristofa.brave.SpanCollector; //导入依赖的package包/类
public void setSpanCollector(SpanCollector spanCollector) {
    this.spanCollector = spanCollector;
}
 

import com.github.kristofa.brave.SpanCollector; //导入依赖的package包/类
public static SpanCollector build(final JsonObject json) {
  return new ScribeSpanCollector(json.getString("host", "localhost"),
      json.getInteger("port", 8410),
      getParams(json.getJsonObject("params", new JsonObject())));
}
 

import com.github.kristofa.brave.SpanCollector; //导入依赖的package包/类
public SpanCollector getSpanCollector() {
    return spanCollector;
}
 

import com.github.kristofa.brave.SpanCollector; //导入依赖的package包/类
/**
 * The collector to use for sending zipkin span events to the zipkin server.
 */
public void setSpanCollector(SpanCollector spanCollector) {
    this.spanCollector = spanCollector;
}