io.opentracing.Scope类的使用及代码示例

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

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

Scope介绍

[英]A Scope formalizes the activation and deactivation of a Span, usually from a CPU standpoint.

Many times a Span will be extant (in that Span#finish() has not been called) despite being in a non-runnable state from a CPU/scheduler standpoint. For instance, a Span representing the client side of an RPC will be unfinished but blocked on IO while the RPC is still outstanding. A Scope defines when a given Span is scheduled and on the path.
[中]作用域通常从CPU的角度对范围的激活和停用进行形式化。
很多时候，尽管从CPU/调度程序的角度来看处于不可运行状态，但一个Span仍然存在（在该Span中，尚未调用#finish（））。例如，代表RPC客户端的跨度将未完成，但在RPC仍然未完成时在IO上被阻止。作用域定义了给定跨度*的计划时间和路径。

代码示例

代码示例来源：origin: stagemonitor/stagemonitor

  1. @Override
  2. public Span activeSpan() {
  3.   return scopeManager.active().span();
  4. }

代码示例来源：origin: stagemonitor/stagemonitor

  1. public void monitorStop() {
  2.   final Scope activeScope = tracingPlugin.getTracer().scopeManager().active();
  3.   if (activeScope != null) {
  4.     final Span currentSpan = activeScope.span();
  5.     final SpanContextInformation info = SpanContextInformation.get(currentSpan);
  6.     if (info != null) {
  7.       long overhead2 = System.nanoTime();
  8.       trackOverhead(info.getOverhead1(), overhead2);
  9.     }
  10.     activeScope.close();
  11.   }
  12. }

代码示例来源：origin: qunarcorp/qmq

  1. private void closeTrace() {
  2.   if (traceScope == null) return;
  3.   traceScope.close();
  4. }

代码示例来源：origin: qunarcorp/qmq

  1. @Override
  2.   public void postOnMessage(Message message, Throwable e, Map<String, Object> filterContext) {
  3.     Object o = filterContext.get(TRACE_OBJECT);
  4.     if (!(o instanceof Span)) return;
  5.     Scope scope = tracer.scopeManager().activate((Span) o, true);
  6.     scope.close();
  7.   }
  8. }

代码示例来源：origin: stagemonitor/stagemonitor

  1. public SpanContextInformation monitorStart(MonitoredRequest monitoredRequest) {
  2.   final long start = System.nanoTime();
  3.   final Scope scope = monitoredRequest.createScope();
  4.   final SpanContextInformation info = SpanContextInformation.get(scope.span());
  5.   if (info != null) {
  6.     info.setOverhead1(System.nanoTime() - start);
  7.   }
  8.   return info;
  9. }

代码示例来源：origin: stagemonitor/stagemonitor

  1. @Override
  2. public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
  3.   final Scope scope = new ExternalHttpRequest(tracingPlugin.getTracer(), request.getMethod().toString(), removeQuery(request.getURI()), request.getURI().getHost(), request.getURI().getPort()).createScope();
  4.   try {
  5.     Profiler.start(request.getMethod().toString() + " " + request.getURI() + " ");
  6.     tracingPlugin.getTracer().inject(scope.span().context(), Format.Builtin.HTTP_HEADERS, new SpringHttpRequestInjectAdapter(request));
  7.     return execution.execute(request, body);
  8.   } finally {
  9.     Profiler.stop();
  10.     scope.close();
  11.   }
  12. }

代码示例来源：origin: stagemonitor/stagemonitor

  1. @Override
  2. public void close(MessageContext context) {
  3.   if (!shouldExecute(context)) {
  4.     return;
  5.   }
  6.   tracingPlugin.getTracer().scopeManager().active().close();
  7. }

代码示例来源：origin: qunarcorp/qmq

  1. public static void setTag(String key, String value, Tracer tracer) {
  2.   if (tracer == null) {
  3.     tracer = GlobalTracer.get();
  4.   }
  5.   Scope scope = tracer.scopeManager().active();
  6.   if (scope == null) return;
  7.   scope.span().setTag(key, value);
  8. }

代码示例来源：origin: qunarcorp/qmq

  1. static void ackWithTrace(PulledMessage message, Throwable throwable) {
  2.     Scope scope = GlobalTracer.get()
  3.         .buildSpan("Qmq.Consume.Ack")
  4.         .withTag("subject", message.getSubject())
  5.         .withTag("messageId", message.getMessageId())
  6.         .withTag("consumerGroup", message.getStringProperty(BaseMessage.keys.qmq_consumerGroupName))
  7.         .startActive(true);
  8.     try {
  9.       ack(message, throwable);
  10.     } catch (Exception e) {
  11.       scope.span().log("ack_failed");
  12.       LOGGER.error("ack exception.", e);
  13.       Metrics.counter("qmq_pull_ackError", SUBJECT_ARRAY, new String[]{message.getSubject()}).inc();
  14.     } finally {
  15.       if (scope != null) {
  16.         scope.close();
  17.       }
  18.     }
  19.   }
  20. }

代码示例来源：origin: stagemonitor/stagemonitor

  1. @Test
  2. public void testDontMonitorClientRootSpans() throws Exception {
  3.   MockTracer tracer = new MockTracer();
  4.   new AbstractExternalRequest(tracer) {
  5.     @Override
  6.     protected String getType() {
  7.       return "jdbc";
  8.     }
  9.   }.createScope().close();
  10.   assertThat(tracer.finishedSpans().get(0).tags().get(Tags.SAMPLING_PRIORITY.getKey())).isEqualTo(0);
  11. }

代码示例来源：origin: stagemonitor/stagemonitor

  1. public static SpanContextInformation getCurrent() {
  2.   final Scope activeScope = GlobalTracer.get().scopeManager().active();
  3.   if (activeScope == null) {
  4.     return null;
  5.   }
  6.   return forSpan(activeScope.span());
  7. }

代码示例来源：origin: com.uber.jaeger/jaeger-context

  1. /** Deactivates the current active span and returns it. If there is no active span returns null. */
  2. @Override
  3. public Span pop() {
  4.  Scope scope = scopeManager.active();
  5.  if (scope == null) {
  6.   return null;
  7.  }
  8.  Span span = scope.span();
  9.  scope.close();
  10.  return span;
  11. }

代码示例来源：origin: stagemonitor/stagemonitor

  1. @Test
  2. public void testHonorDoNotTrack() throws Exception {
  3.   when(servletPlugin.isHonorDoNotTrackHeader()).thenReturn(true);
  4.   final MockHttpServletRequest request = new MockHttpServletRequest();
  5.   request.addHeader("dnt", "1");
  6.   Scope activeScope = new MonitoredHttpRequest(request, mock(StatusExposingByteCountingServletResponse.class),
  7.       mock(FilterChain.class), configuration, mock(ExecutorService.class)).createScope();
  8.   SpanWrapper span = SpanContextInformation.getCurrent().getSpanWrapper();
  9.   assertThat(span.getNumberTag(Tags.SAMPLING_PRIORITY.getKey())).isEqualTo(0);
  10.   activeScope.close();
  11. }

代码示例来源：origin: qunarcorp/qmq

  1. public static void recordEvent(String event, Tracer tracer) {
  2.   if (tracer == null) {
  3.     tracer = GlobalTracer.get();
  4.   }
  5.   Scope scope = tracer.scopeManager().active();
  6.   if (scope == null) return;
  7.   scope.span().log(event);
  8. }

代码示例来源：origin: io.opentracing.contrib/opentracing-jdbc

  1. @Override
  2. public int[] executeBatch() throws SQLException {
  3.  Scope scope = buildScopeForBatch();
  4.  try {
  5.   return statement.executeBatch();
  6.  } catch (Exception e) {
  7.   JdbcTracingUtils.onError(e, scope.span());
  8.   throw e;
  9.  } finally {
  10.   scope.close();
  11.  }
  12. }

代码示例来源：origin: stagemonitor/stagemonitor

  1. @Test
  2. public void testNoDoNotTrackHeader() throws Exception {
  3.   when(servletPlugin.isHonorDoNotTrackHeader()).thenReturn(true);
  4.   final MockHttpServletRequest request = new MockHttpServletRequest();
  5.   Scope activeScope = new MonitoredHttpRequest(request, mock(StatusExposingByteCountingServletResponse.class),
  6.       mock(FilterChain.class), configuration, mock(ExecutorService.class)).createScope();
  7.   SpanWrapper span = SpanContextInformation.getCurrent().getSpanWrapper();
  8.   assertThat(span.getNumberTag(Tags.SAMPLING_PRIORITY.getKey())).isNotEqualTo(0);
  9.   activeScope.close();
  10. }

代码示例来源：origin: stagemonitor/stagemonitor

  1. @Override
  2. public Span activeSpan() {
  3.   return scopeManager().active() == null ? null : scopeManager().active().span();
  4. }

代码示例来源：origin: io.opentracing.contrib/opentracing-jdbc

  1. @Override
  2. public ResultSet executeQuery() throws SQLException {
  3.  Scope scope = buildScope("Query", query, connectionInfo, withActiveSpanOnly, ignoredQueries,
  4.    tracer);
  5.  try {
  6.   return preparedStatement.executeQuery();
  7.  } catch (Exception e) {
  8.   JdbcTracingUtils.onError(e, scope.span());
  9.   throw e;
  10.  } finally {
  11.   scope.close();
  12.  }
  13. }

代码示例来源：origin: stagemonitor/stagemonitor

  1. @Test
  2. public void testDontHonorDoNotTrack() throws Exception {
  3.   when(servletPlugin.isHonorDoNotTrackHeader()).thenReturn(false);
  4.   final MockHttpServletRequest request = new MockHttpServletRequest();
  5.   request.addHeader("dnt", "1");
  6.   Scope activeScope = new MonitoredHttpRequest(request, mock(StatusExposingByteCountingServletResponse.class),
  7.       mock(FilterChain.class), configuration, mock(ExecutorService.class)).createScope();
  8.   SpanWrapper span = SpanContextInformation.getCurrent().getSpanWrapper();
  9.   assertThat(span.getNumberTag(Tags.SAMPLING_PRIORITY.getKey())).isNotEqualTo(0);
  10.   activeScope.close();
  11. }

代码示例来源：origin: stagemonitor/stagemonitor

  1. @Override
  2. public Scope createScope() {
  3.   final Scope scope = super.createScope();
  4.   final Span span = scope.span();
  5.   Tags.HTTP_URL.set(span, url);
  6.   Tags.PEER_HOSTNAME.set(span, host);
  7.   Tags.PEER_PORT.set(span, port);
  8.   span.setTag(AbstractExternalRequest.EXTERNAL_REQUEST_METHOD, method);
  9.   return scope;
  10. }

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

scope

相关文章

    查看更多

    热门标签

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

    最新文章

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