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

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

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

Span.localServiceName介绍

暂无

代码示例

代码示例来源：origin: line/armeria

private static Span findSpan(Span[] spans, String serviceName) {
  return Arrays.stream(spans)
         .filter(s -> serviceName.equals(s.localServiceName()))
         .findAny()
         .orElseThrow(() -> new AssertionError(
             "Can't find a Span with service name: " + serviceName));
}

代码示例来源：origin: line/armeria

assertThat(serviceFooSpan.localServiceName()).isEqualTo("service/foo");
assertThat(clientBarSpan.localServiceName()).isEqualTo("client/bar");
assertThat(serviceBarSpan.localServiceName()).isEqualTo("service/bar");
assertThat(clientQuxSpan.localServiceName()).isEqualTo("client/qux");
assertThat(serviceQuxSpan.localServiceName()).isEqualTo("service/qux");

代码示例来源：origin: line/armeria

@Test(timeout = 20000)
public void shouldSubmitSpanWhenRequestIsSampled() throws Exception {
  final SpanCollectingReporter reporter = testServiceInvocation(1.0f);
  // check span name
  final Span span = reporter.spans().take();
  assertThat(span.name()).isEqualTo(TEST_METHOD);
  // check kind
  assertThat(span.kind()).isSameAs(Kind.SERVER);
  // 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/trustin",
      "http.status_code", "200",
      "http.url", "none+h2c://foo.com/hello/trustin"));
  // check service name
  assertThat(span.localServiceName()).isEqualTo(TEST_SERVICE);
}

代码示例来源：origin: line/armeria

assertThat(clientFooSpan.localServiceName()).isEqualTo("client/foo");
assertThat(serviceFooSpan.localServiceName()).isEqualTo("service/foo");
assertThat(clientBarSpan.localServiceName()).isEqualTo("client/bar");
assertThat(serviceBarSpan.localServiceName()).isEqualTo("service/bar");
assertThat(clientQuxSpan.localServiceName()).isEqualTo("client/qux");
assertThat(serviceQuxSpan.localServiceName()).isEqualTo("service/qux");

代码示例来源：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.smartup.zipkin/zipkin-datadog-reporter-core

@JsonGetter("service")
public String getServiceName() {
 Map<String, String> tags = delegateSpan.tags();
 if (tags.containsKey("redis.args")) {
  return "redis";
 }
 if (tags.containsKey("sql.query")) {
  return "sql";
 }
 return delegateSpan.localServiceName();
}

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

String service = s.localServiceName() != null ? s.localServiceName() : "";
String span =
 null != s.name() ? s.name() : ""; // Empty value allows for api queries without span name
if (null == s.localServiceName()) continue; // don't index further w/o a service name

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

String serviceName = currentSpan.localServiceName();
String remoteServiceName = currentSpan.remoteServiceName();
if (kind == null) {
String remoteAncestorName;
if (remoteAncestor != null
 && (remoteAncestorName = remoteAncestor.localServiceName()) != null) {

代码示例来源：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.github.scouter-project/zipkin-storage-scouter-udp

public static void registerZipkinObj(Span span, ScouterConfig conf) {
  String objName = ScouterConstants.toScouterObjName(span.localServiceName());
  int objHash = HashUtil.hash(objName);
  long registered = objSentMap.get(objHash);
  long now = System.currentTimeMillis();
  if (registered != 0 && now - registered < 30 * 1000) {
    return;
  }
  ObjectPack p = new ObjectPack();
  p.objType = ScouterConstants.toScouterObjType(span.localServiceName(), conf);
  p.objName = objName;
  p.objHash = objHash;
  if (span.localEndpoint() != null) {
    p.address = span.localEndpoint().ipv4() + ":" + span.localEndpoint().portAsInt();
  }
  p.tags.put(scouter.lang.constants.ScouterConstants.TAG_OBJ_DETECTED_TYPE, "zipkin");
  p.tags.put(ObjectPack.TAG_KEY_DEAD_TIME, 300 * 1000);
  objSentMap.put(objHash, now);
  sendHeartBeat(p);
  if (conf.isDebug()) {
    logger.info("Object heartbeat: " + p);
  }
}

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

String localServiceName = span.localServiceName();

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

/** ServiceName can be set late, but it should be consistent across annotations. */
@Test public void serviceNameAppliesRetroactively() throws Exception {
 advanceAndRecord(0, root, new Annotation.Rpc("GET"));
 advanceAndRecord(0, root, Annotation.ServerRecv$.MODULE$);
 advanceAndRecord(0, root, new Annotation.ServiceName("frontend"));
 advanceAndRecord(15, root, Annotation.ServerSend$.MODULE$);
 Span span = spansSent.take();
 assertThat(span.localServiceName()).isEqualTo("frontend");
}

代码示例来源：origin: com.wavefront/proxy

String serviceName = zipkinSpan.localServiceName() == null ? DEFAULT_SERVICE :
  zipkinSpan.localServiceName();
annotations.add(new Annotation(SERVICE_TAG_KEY, serviceName));

代码示例来源：origin: wavefrontHQ/java

String serviceName = zipkinSpan.localServiceName() == null ? DEFAULT_SERVICE :
  zipkinSpan.localServiceName();
annotations.add(new Annotation(SERVICE_TAG_KEY, serviceName));

代码示例来源：origin: io.github.scouter-project/zipkin-storage-scouter-udp

Endpoint remoteEndPoint = span.remoteEndpoint();
pack.objHash = sendObjName(ScouterConstants.toScouterObjName(span.localServiceName()));
pack.localEndpointServiceName = sendObjName(span.localServiceName());
pack.remoteEndpointServiceName = sendObjName(span.remoteServiceName());
pack.localEndpointIp = localEndPoint != null ? localEndPoint.ipv4Bytes() : null;

代码示例来源：origin: io.github.jeqo.zipkin/zipkin-storage-kafka

.withValueSerde(spansSerde));
spanStream.map((traceId, span) -> KeyValue.pair(span.localServiceName(), span.name()))
  .groupByKey(Grouped.with(Serdes.String(), Serdes.String()))
  .aggregate(HashSet::new,

内容来源于网络，如有侵权，请联系作者删除！

Span

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com