本文整理了Java中zipkin2.Span.remoteServiceName()
方法的一些代码示例,展示了Span.remoteServiceName()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Span.remoteServiceName()
方法的具体详情如下:
包路径:zipkin2.Span
类名称:Span
方法名:remoteServiceName
暂无
代码示例来源:origin: openzipkin/brave
.isEqualTo("get /foo");
assertThat(span.remoteServiceName())
.isEqualTo("remote-service");
代码示例来源:origin: line/armeria
@Test(timeout = 20000)
public void shouldSubmitSpanWhenSampled() throws Exception {
final SpanCollectingReporter reporter = new SpanCollectingReporter();
final Tracing tracing = Tracing.newBuilder()
.localServiceName(TEST_SERVICE)
.spanReporter(reporter)
.sampler(Sampler.create(1.0f))
.build();
testRemoteInvocation(tracing, null);
// check span name
final Span span = reporter.spans().take();
assertThat(span.name()).isEqualTo(TEST_SPAN);
// check kind
assertThat(span.kind()).isSameAs(Kind.CLIENT);
// only one span should be submitted
assertThat(reporter.spans().poll(1, TimeUnit.SECONDS)).isNull();
// check # of annotations (we add wire annotations)
assertThat(span.annotations()).hasSize(2);
// check tags
assertThat(span.tags()).containsAllEntriesOf(ImmutableMap.of(
"http.host", "foo.com",
"http.method", "POST",
"http.path", "/hello/armeria",
"http.status_code", "200",
"http.url", "none+h2c://foo.com/hello/armeria"));
// check service name
assertThat(span.localServiceName()).isEqualTo(TEST_SERVICE);
// check remote service name
assertThat(span.remoteServiceName()).isEqualTo("foo.com");
}
代码示例来源:origin: line/armeria
@Test(timeout = 20000)
public void shouldSubmitSpanWithCustomRemoteName() throws Exception {
final SpanCollectingReporter reporter = new SpanCollectingReporter();
final Tracing tracing = Tracing.newBuilder()
.localServiceName(TEST_SERVICE)
.spanReporter(reporter)
.sampler(Sampler.create(1.0f))
.build();
testRemoteInvocation(tracing, "fooService");
// check span name
final Span span = reporter.spans().take();
// check tags
assertThat(span.tags()).containsAllEntriesOf(ImmutableMap.of(
"http.host", "foo.com",
"http.method", "POST",
"http.path", "/hello/armeria",
"http.status_code", "200",
"http.url", "none+h2c://foo.com/hello/armeria"));
// check service name
assertThat(span.localServiceName()).isEqualTo(TEST_SERVICE);
// check remote service name, lower-cased
assertThat(span.remoteServiceName()).isEqualTo("fooservice");
}
代码示例来源:origin: io.zipkin.zipkin2/zipkin-storage-cassandra
if (null != s.remoteServiceName()) { // allows getServices to return remote service names
serviceSpans.add(insertServiceSpanName.newInput(s.remoteServiceName(), span));
代码示例来源:origin: io.zipkin.zipkin2/zipkin
@Override
public synchronized Call<Void> accept(List<Span> spans) {
int delta = spans.size();
int spansToRecover = (spansByTraceIdTimeStamp.size() + delta) - maxSpanCount;
evictToRecoverSpans(spansToRecover);
for (Span span : spans) {
long timestamp = span.timestampAsLong();
String lowTraceId = lowTraceId(span.traceId());
TraceIdTimestamp traceIdTimeStamp = new TraceIdTimestamp(lowTraceId, timestamp);
spansByTraceIdTimeStamp.put(traceIdTimeStamp, span);
traceIdToTraceIdTimeStamps.put(lowTraceId, traceIdTimeStamp);
acceptedSpanCount++;
if (!searchEnabled) continue;
String spanName = span.name();
if (span.localServiceName() != null) {
serviceToTraceIds.put(span.localServiceName(), lowTraceId);
if (spanName != null) serviceToSpanNames.put(span.localServiceName(), spanName);
}
if (span.remoteServiceName() != null) {
serviceToTraceIds.put(span.remoteServiceName(), lowTraceId);
if (spanName != null) serviceToSpanNames.put(span.remoteServiceName(), spanName);
}
for (Map.Entry<String, String> tag : span.tags().entrySet()) {
if (autocompleteKeys.contains(tag.getKey())) {
autocompleteTags.put(tag.getKey(), tag.getValue());
}
}
}
return Call.create(null /* Void == null */);
}
代码示例来源:origin: io.zipkin.zipkin2/zipkin
String remoteServiceName = currentSpan.remoteServiceName();
if (kind == null) {
代码示例来源:origin: io.zipkin.brave/brave-instrumentation-http-tests
.isEqualTo("get /foo");
assertThat(span.remoteServiceName())
.isEqualTo("remote-service");
代码示例来源:origin: io.github.scouter-project/zipkin-storage-scouter-udp
pack.remoteEndpointServiceName = sendObjName(span.remoteServiceName());
pack.localEndpointIp = localEndPoint != null ? localEndPoint.ipv4Bytes() : null;
pack.remoteEndpointIp = remoteEndPoint != null ? remoteEndPoint.ipv4Bytes() : null;
内容来源于网络,如有侵权,请联系作者删除!