zipkin2.Span.newBuilder()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(5.7k)|赞(0)|评价(0)|浏览(147)

本文整理了Java中zipkin2.Span.newBuilder()方法的一些代码示例,展示了Span.newBuilder()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Span.newBuilder()方法的具体详情如下:
包路径:zipkin2.Span
类名称:Span
方法名:newBuilder

Span.newBuilder介绍

暂无

代码示例

代码示例来源:origin: openzipkin/brave

@Benchmark public Span.Builder convertBigClientSpan() {
 Span.Builder builder = Span.newBuilder();
 converter.convert(bigClientMutableSpan, builder);
 return builder;
}

代码示例来源:origin: openzipkin/brave

/**
 * Tests converting into a builder type. This isolates the performance of walking over the mutable
 * data.
 */
@Benchmark public Span.Builder convertServerSpan() {
 Span.Builder builder = Span.newBuilder();
 converter.convert(serverMutableSpan, builder);
 return builder;
}

代码示例来源:origin: openzipkin/brave

@Override public boolean handle(TraceContext context, MutableSpan span) {
 if (!Boolean.TRUE.equals(context.sampled())) return true;
 Span.Builder builderWithContextData = Span.newBuilder()
   .traceId(context.traceIdString())
   .parentId(context.parentIdString())
   .id(context.spanIdString());
 if (context.debug()) builderWithContextData.debug(true);
 converter.convert(span, builderWithContextData);
 spanReporter.report(builderWithContextData.build());
 return true;
}

代码示例来源:origin: io.zipkin.zipkin2/zipkin

Span.Builder newSpanBuilder(V1Span source, Endpoint e) {
 Span.Builder result = newBuilder(Span.newBuilder(), source).localEndpoint(e);
 spans.add(result);
 return result;
}

代码示例来源:origin: io.zipkin.brave/brave-core

/** Returns a json representation of this endpoint */
@Override public String toString() {
 // expensive, but only used when people are debugging and cheaper than maintaining json codec
 Span fake = Span.newBuilder().traceId(0, 1).id(1).localEndpoint(toV2()).build();
 String jsonSpan = new String(SpanBytesEncoder.JSON_V2.encode(fake), UTF_8);
 return jsonSpan.substring(70, jsonSpan.length() - 1);
}

代码示例来源:origin: Nike-Inc/wingtips

@Test
public void spanCompleted_converts_to_zipkin_span_and_passes_it_to_zipkinSpanReporter() {
  // given
  zipkin2.Span zipkinSpan = zipkin2.Span.newBuilder().traceId("42").id("4242").name("foo").build();
  doReturn(zipkinSpan).when(spanConverterMock).convertWingtipsSpanToZipkinSpan(any(Span.class), any(Endpoint.class));
  // when
  listener.spanCompleted(spanMock);
  // then
  verify(spanConverterMock).convertWingtipsSpanToZipkinSpan(spanMock, listener.zipkinEndpoint);
  verify(spanReporterMock).report(zipkinSpan);
}

代码示例来源:origin: io.zipkin.brave/brave

@Override public boolean handle(TraceContext context, MutableSpan span) {
 if (!Boolean.TRUE.equals(context.sampled())) return true;
 Span.Builder builderWithContextData = Span.newBuilder()
   .traceId(context.traceIdString())
   .parentId(context.parentIdString())
   .id(context.spanIdString());
 if (context.debug()) builderWithContextData.debug(true);
 converter.convert(span, builderWithContextData);
 spanReporter.report(builderWithContextData.build());
 return true;
}

代码示例来源:origin: Nike-Inc/wingtips

.newBuilder()
.id(spanId)
.name(wingtipsSpan.getSpanName())

代码示例来源:origin: com.nike.wingtips/wingtips-zipkin2

.newBuilder()
.id(spanId)
.name(wingtipsSpan.getSpanName())

代码示例来源:origin: org.springframework.cloud/spring-cloud-sleuth-zipkin2

convertedSpan = adjuster.adjust(span);
zipkin2.Span.Builder zipkinSpan = zipkin2.Span.newBuilder();
zipkinSpan.localEndpoint(this.endpointLocator.local());
processLogs(convertedSpan, zipkinSpan);

代码示例来源:origin: io.zipkin.dependencies/zipkin-dependencies-cassandra3

@Override public Span call(CassandraRow row) {
 String traceId = CassandraDependenciesJob.traceId(row), spanId = row.getString("id");
 Span.Builder builder = Span.newBuilder()
   .traceId(traceId)
   .parentId(row.getString("parent_id"))
   .id(spanId)
   .timestamp(row.getLong("ts"))
   .shared(row.getBoolean("shared"));
 Map<String, String> tags = row.getMap(
   "tags", TypeConverter.StringConverter$.MODULE$, TypeConverter.StringConverter$.MODULE$);
 String error = tags.get("error");
 if (error != null) builder.putTag("error", error);
 String kind = row.getString("kind");
 if (kind != null) {
  try {
   builder.kind(Span.Kind.valueOf(kind));
  } catch (IllegalArgumentException ignored) {
   log.debug("couldn't parse kind {} in span {}/{}", kind, traceId, spanId);
  }
 }
 Endpoint localEndpoint = readEndpoint(row, "l_ep");
 if (localEndpoint != null) {
  builder.localEndpoint(localEndpoint);
 }
 Endpoint remoteEndpoint = readEndpoint(row, "r_ep");
 if (remoteEndpoint != null) {
  builder.remoteEndpoint(remoteEndpoint);
 }
 return builder.build();
}

代码示例来源:origin: io.zipkin.zipkin2/zipkin-storage-cassandra

if (traceIdHigh != null) traceId = traceIdHigh + traceId;
Span.Builder builder =
  Span.newBuilder()
    .traceId(traceId)
    .parentId(row.getString("parent_id"))

代码示例来源:origin: alipay/sofa-tracer

Span.Builder zipkinSpanBuilder = Span.newBuilder();
SofaTracerSpanContext context = sofaTracerSpan.getSofaTracerSpanContext();
zipkinSpanBuilder.traceId(context.getTraceId());

代码示例来源:origin: com.alipay.sofa/sofa-tracer-zipkin-plugin

Span.Builder zipkinSpanBuilder = Span.newBuilder();
SofaTracerSpanContext context = sofaTracerSpan.getSofaTracerSpanContext();
zipkinSpanBuilder.traceId(context.getTraceId());

代码示例来源:origin: census-instrumentation/opencensus-java

Span.newBuilder()
  .traceId(TRACE_ID)
  .parentId(PARENT_SPAN_ID)

代码示例来源:origin: census-instrumentation/opencensus-java

Span.newBuilder()
  .traceId(context.getTraceId().toLowerBase16())
  .id(context.getSpanId().toLowerBase16())

代码示例来源:origin: census-instrumentation/opencensus-java

Span.newBuilder()
  .traceId(TRACE_ID)
  .parentId(PARENT_SPAN_ID)

代码示例来源:origin: census-instrumentation/opencensus-java

Span.newBuilder()
  .traceId(TRACE_ID)
  .parentId(PARENT_SPAN_ID)

代码示例来源:origin: census-instrumentation/opencensus-java

Span.newBuilder()
  .traceId(TRACE_ID)
  .parentId(PARENT_SPAN_ID)

代码示例来源:origin: openzipkin/zipkin-finagle

Span.newBuilder()
  .traceId(FinagleTestObjects.root.traceId().toString())
  .id(FinagleTestObjects.root.spanId().toLong())

相关文章