com.nike.wingtips.Tracer.completeSubSpan()方法的使用及代码示例

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

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

Tracer.completeSubSpan介绍

[英]Completes the current child sub-span by calling #completeAndLogSpan(Span,boolean) on it and then #configureMDC(Span) on the sub-span's parent (which becomes the new current span).

WARNING: This only works if there are at least 2 spans in the #currentSpanStackThreadLocal stack - one for the child sub-span and one for the parent span. If you're trying to complete the overall request's span you should be calling #completeRequestSpan() instead. If there are 0 or 1 spans on the stack then this method will log an error and do nothing.
[中]通过在当前子跨度上调用#completeAndLogSpan（span，布尔值），然后在子跨度的父跨度上调用#configureMDC（span）（成为新的当前跨度），完成当前子跨度。
警告：仅当#currentSpanStackThreadLocal堆栈中至少有两个跨距时，此选项才有效-一个用于子跨距，一个用于父跨距。如果要完成整个请求的跨度，则应调用#completeRequestSpan（）。如果堆栈上有0或1个跨距，则此方法将记录错误，而不执行任何操作。

代码示例

代码示例来源：origin: com.nike.riposte/riposte-core

/**
 * Helper method for creating a `CompletableFuture` that has the `Supplier` wrapped around a SubSpan.
 * <p>
 * You would prefer this method over the above when your `Supplier` has logic that makes an outbound/downstream call
 * and you do not want the use of a `CircuitBreaker`.
 * <p>
 * You would prefer this method over {@link #supplyAsync(String, Supplier, CircuitBreaker, Executor, ChannelHandlerContext)}
 * when your `Supplier` has logic that you would like wrapped with distributed tracing logs and not use a {@link CircuitBreaker}
 * <p>
 * An example would be using a client SDK that makes blocking HTTP calls.
 * <p>
 * The SubSpan purpose will be set to `CLIENT` as this is the typical use case when utilizing these helpers.
 * <p>
 * <pre>
 * AsyncNettyHelper.supplyAsync("someWorkToBeDone", () -> {
 *      //do some work in a background thread
 *      return VOID;
 * }, executor, ctx);
 * </pre>
 */
public static <U> CompletableFuture<U> supplyAsync(String subSpanName, Supplier<U> f, Executor executor, ChannelHandlerContext ctx) {
  return CompletableFuture.supplyAsync(supplierWithTracingAndMdc(() -> {
    try {
      Tracer.getInstance().startSubSpan(subSpanName, Span.SpanPurpose.CLIENT);
      return f.get();
    } finally {
      Tracer.getInstance().completeSubSpan();
    }
  }, ctx), executor);
}

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

/**
 * Helper method for creating a `CompletableFuture` that has the `Supplier` wrapped around a SubSpan.
 * <p>
 * You would prefer this method over the above when your `Supplier` has logic that makes an outbound/downstream call
 * and you do not want the use of a `CircuitBreaker`.
 * <p>
 * You would prefer this method over {@link #supplyAsync(String, Supplier, CircuitBreaker, Executor, ChannelHandlerContext)}
 * when your `Supplier` has logic that you would like wrapped with distributed tracing logs and not use a {@link CircuitBreaker}
 * <p>
 * An example would be using a client SDK that makes blocking HTTP calls.
 * <p>
 * The SubSpan purpose will be set to `CLIENT` as this is the typical use case when utilizing these helpers.
 * <p>
 * <pre>
 * AsyncNettyHelper.supplyAsync("someWorkToBeDone", () -> {
 *      //do some work in a background thread
 *      return VOID;
 * }, executor, ctx);
 * </pre>
 */
public static <U> CompletableFuture<U> supplyAsync(String subSpanName, Supplier<U> f, Executor executor, ChannelHandlerContext ctx) {
  return CompletableFuture.supplyAsync(supplierWithTracingAndMdc(() -> {
    try {
      Tracer.getInstance().startSubSpan(subSpanName, Span.SpanPurpose.CLIENT);
      return f.get();
    } finally {
      Tracer.getInstance().completeSubSpan();
    }
  }, ctx), executor);
}

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

@Test
public void completeSubSpan_should_do_nothing_if_there_is_only_one_span_on_the_stack() {
  // given: a single span on the stack
  Tracer.getInstance().startRequestWithRootSpan("somespan");
  assertThat(Tracer.getInstance().getCurrentSpan()).isNotNull();
  assertThat(getSpanStackSize()).isEqualTo(1);
  Span span = Tracer.getInstance().getCurrentSpan();
  assertThat(span).isNotNull();
  assertThat(span.getSpanName()).isEqualTo("somespan");
  // when: completeSubSpan() is called
  Tracer.getInstance().completeSubSpan();
  // then: nothing should be done because the stack only has one thing on it and completeSubSpan() requires at least two spans
  assertThat(span.isCompleted()).isFalse();
  assertThat(Tracer.getInstance().getCurrentSpan()).isSameAs(span);
  assertThat(getSpanStackSize()).isEqualTo(1);
}

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

@Test
public void completeSubSpan_should_do_nothing_if_the_span_stack_is_null() {
  // given: a null span stack
  assertThat(Tracer.getInstance().getCurrentSpan()).isNull();
  assertThat(getSpanStackSize()).isEqualTo(0);
  assertThat(getSpanStackFromTracer()).isNull();
  // when: completeSubSpan() is called
  Tracer.getInstance().completeSubSpan();
  // then: nothing should be done because the stack is null
  assertThat(Tracer.getInstance().getCurrentSpan()).isNull();
  assertThat(getSpanStackSize()).isEqualTo(0);
  assertThat(getSpanStackFromTracer()).isNull();
}

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

@Test
public void spanLifecycleListener_spanCompleted_is_called_when_subspan_is_completed() {
  // given
  SpanLifecycleListener listener1 = mock(SpanLifecycleListener.class);
  SpanLifecycleListener listener2 = mock(SpanLifecycleListener.class);
  Tracer tracer = Tracer.getInstance();
  tracer.addSpanLifecycleListener(listener1);
  tracer.addSpanLifecycleListener(listener2);
  tracer.startRequestWithRootSpan("newspan");
  Span subspan = tracer.startSubSpan("subspan", SpanPurpose.LOCAL_ONLY);
  verify(listener1).spanStarted(subspan);
  verify(listener1, times(0)).spanCompleted(subspan);
  verify(listener2).spanStarted(subspan);
  verify(listener2, times(0)).spanCompleted(subspan);
  // when
  tracer.completeSubSpan();
  // then
  verify(listener1).spanCompleted(subspan);
  verify(listener2).spanCompleted(subspan);
}

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

case MANAGED_CURRENT_SUB_SPAN:
  completeSubSpan();
  break;
case MANAGED_NON_CURRENT_ROOT_SPAN: //intentional fall-through

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

@Test
public void getCurrentSpanStackCopy_returns_copy_of_stack_not_original() {
  // given
  Tracer tracer = Tracer.getInstance();
  Span parentSpan = tracer.startRequestWithRootSpan("foo");
  Span subspan = tracer.startSubSpan("bar", SpanPurpose.LOCAL_ONLY);
  assertThat(MDC.get(Tracer.TRACE_ID_MDC_KEY)).isEqualTo(subspan.getTraceId());
  assertThat(MDC.get(Tracer.SPAN_JSON_MDC_KEY)).isEqualTo(subspan.toJSON());
  // when
  Deque<Span> stack = tracer.getCurrentSpanStackCopy();
  // Verify that the returned stack contains both spans
  assertThat(stack).hasSize(2);
  assertThat(stack.peek()).isEqualTo(subspan);
  assertThat(stack.peekLast()).isEqualTo(parentSpan);
  // Clear the returned stack
  stack.clear();
  assertThat(stack.isEmpty()).isTrue();
  // then
  // Now verify that tracer still points to a stack that contains both spans. This proves that getCurrentSpanStackCopy() returned a copy, not the original
  assertThat(tracer.getCurrentSpan()).isEqualTo(subspan);
  assertThat(MDC.get(Tracer.TRACE_ID_MDC_KEY)).isEqualTo(subspan.getTraceId());
  assertThat(MDC.get(Tracer.SPAN_JSON_MDC_KEY)).isEqualTo(subspan.toJSON());
  tracer.completeSubSpan();
  assertThat(tracer.getCurrentSpan()).isEqualTo(parentSpan);
  assertThat(MDC.get(Tracer.TRACE_ID_MDC_KEY)).isEqualTo(parentSpan.getTraceId());
  assertThat(MDC.get(Tracer.SPAN_JSON_MDC_KEY)).isEqualTo(parentSpan.toJSON());
}

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

@Test
public void spanLifecycleListener_spanCompleted_is_not_called_if_subspan_was_already_completed() {
  // given
  SpanLifecycleListener listener1 = mock(SpanLifecycleListener.class);
  SpanLifecycleListener listener2 = mock(SpanLifecycleListener.class);
  Tracer tracer = Tracer.getInstance();
  tracer.addSpanLifecycleListener(listener1);
  tracer.addSpanLifecycleListener(listener2);
  tracer.startRequestWithRootSpan("newspan");
  Span subspan = tracer.startSubSpan("subspan", SpanPurpose.LOCAL_ONLY);
  subspan.complete();
  verify(listener1).spanStarted(subspan);
  verify(listener1, times(0)).spanCompleted(subspan);
  verify(listener2).spanStarted(subspan);
  verify(listener2, times(0)).spanCompleted(subspan);
  // when
  tracer.completeSubSpan();
  // then
  verify(listener1, never()).spanCompleted(subspan);
  verify(listener2, never()).spanCompleted(subspan);
}

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

tracer.completeSubSpan();

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

Tracer.getInstance().completeRequestSpan();
else
  Tracer.getInstance().completeSubSpan();

代码示例来源：origin: com.nike.riposte/riposte-core

Tracer.getInstance().completeRequestSpan();
else
  Tracer.getInstance().completeSubSpan();

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

@Test
public void completeSubSpan_should_complete_the_sub_span() {
  // given: an already-started span AND a subspan
  Tracer.getInstance().startRequestWithRootSpan("parentspan");
  Span parentSpan = Tracer.getInstance().getCurrentSpan();
  assertThat(parentSpan.getSpanName()).isEqualTo("parentspan");
  Tracer.getInstance().startSubSpan("subspan", SpanPurpose.LOCAL_ONLY);
  Span subspan = Tracer.getInstance().getCurrentSpan();
  assertThat(subspan.getSpanName()).isEqualTo("subspan");
  assertThat(getSpanStackSize()).isEqualTo(2);
  assertThat(parentSpan.isCompleted()).isFalse();
  assertThat(subspan.isCompleted()).isFalse();
  // when: completeSubSpan() is called
  long beforeNanoTime = System.nanoTime();
  Tracer.getInstance().completeSubSpan();
  long afterNanoTime = System.nanoTime();
  // then: only the subspan should be completed, the stack decremented by 1, the current span set to the parent, and the MDC configured to point to the parent
  assertThat(parentSpan.isCompleted()).isFalse();
  assertThat(subspan.isCompleted()).isTrue();
  verifyDurationBetweenLowerAndUpperBounds(subspan, beforeNanoTime, afterNanoTime);
  assertThat(Tracer.getInstance().getCurrentSpan()).isNotNull();
  assertThat(Tracer.getInstance().getCurrentSpan()).isSameAs(parentSpan);
  assertThat(getSpanStackSize()).isEqualTo(1);
  assertThat(MDC.get(Tracer.TRACE_ID_MDC_KEY)).isEqualTo(parentSpan.getTraceId());
  assertThat(MDC.get(Tracer.SPAN_JSON_MDC_KEY)).isEqualTo(parentSpan.toJSON());
}

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

@Test
public void handleSpanCloseMethod_does_nothing_if_span_is_already_completed() {
  // given
  Span rootSpan = Tracer.getInstance().startRequestWithRootSpan("root");
  Span subspan = Tracer.getInstance().startSubSpan("subspan", SpanPurpose.LOCAL_ONLY);
  Tracer.getInstance().completeSubSpan();
  assertThat(subspan.isCompleted()).isTrue();
  assertThat(rootSpan.isCompleted()).isFalse();
  assertThat(Tracer.getInstance().getCurrentSpan()).isSameAs(rootSpan);
  assertThat(Tracer.getInstance().getCurrentSpanStackCopy()).isEqualTo(singletonList(rootSpan));
  // when
  Tracer.getInstance().handleSpanCloseMethod(subspan);
  // then
  assertThat(rootSpan.isCompleted()).isFalse();
  assertThat(Tracer.getInstance().getCurrentSpan()).isSameAs(rootSpan);
  assertThat(Tracer.getInstance().getCurrentSpanStackCopy()).isEqualTo(singletonList(rootSpan));
}

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

@Test
public void close_does_nothing_if_span_is_already_completed() {
  // given
  Span rootSpan = Tracer.getInstance().startRequestWithRootSpan("root");
  Span subspan = Tracer.getInstance().startSubSpan("subspan", SpanPurpose.LOCAL_ONLY);
  Tracer.getInstance().completeSubSpan();
  assertThat(subspan.isCompleted()).isTrue();
  assertThat(rootSpan.isCompleted()).isFalse();
  assertThat(Tracer.getInstance().getCurrentSpan()).isSameAs(rootSpan);
  assertThat(Tracer.getInstance().getCurrentSpanStackCopy()).isEqualTo(singletonList(rootSpan));
  // when
  subspan.close();
  // then
  assertThat(rootSpan.isCompleted()).isFalse();
  assertThat(Tracer.getInstance().getCurrentSpan()).isSameAs(rootSpan);
  assertThat(Tracer.getInstance().getCurrentSpanStackCopy()).isEqualTo(singletonList(rootSpan));
}

代码示例来源：origin: com.nike.riposte/riposte-core

Tracer.getInstance().completeRequestSpan();
  else
    Tracer.getInstance().completeSubSpan();
},
distributedSpanStackToUse, mdcContextToUse

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

Tracer.getInstance().completeRequestSpan();
  else
    Tracer.getInstance().completeSubSpan();
},
distributedSpanStackToUse, mdcContextToUse

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

Tracer.getInstance().completeSubSpan();
Tracer.getInstance().completeSubSpan();
Tracer.getInstance().completeRequestSpan();

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

Tracer.getInstance().completeSubSpan();
Tracer.getInstance().completeSubSpan();
Tracer.getInstance().completeRequestSpan();

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

tracer.completeSubSpan();
assertThat(MDC.get(Tracer.TRACE_ID_MDC_KEY)).isEqualTo(reqAParentSpan.getTraceId());
assertThat(MDC.get(Tracer.SPAN_JSON_MDC_KEY)).isEqualTo(reqAParentSpan.toJSON());
tracer.completeSubSpan();
assertThat(MDC.get(Tracer.TRACE_ID_MDC_KEY)).isEqualTo(reqBParentSpan.getTraceId());
assertThat(MDC.get(Tracer.SPAN_JSON_MDC_KEY)).isEqualTo(reqBParentSpan.toJSON());

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

tracer

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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