本文整理了Java中zipkin2.Span.newBuilder()
方法的一些代码示例,展示了Span.newBuilder()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Span.newBuilder()
方法的具体详情如下:
包路径:zipkin2.Span
类名称: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())
内容来源于网络,如有侵权,请联系作者删除!