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

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

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

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;

相关文章