Java SpanId类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.github.kristofa.brave.SpanId类的典型用法代码示例。如果您正苦于以下问题：Java SpanId类的具体用法？Java SpanId怎么用？Java SpanId使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

SpanId类属于com.github.kristofa.brave包，在下文中一共展示了SpanId类的19个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: getTraceData

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
@Override
public TraceData getTraceData() {
    final String sampled = request.getAttachment(RpcAttachment.Sampled.getName());
    if (sampled != null) {
        if (sampled.equals("0") || sampled.toLowerCase().equals("false")) {
            reportTraceIdIfSampled(reporter, TraceId.NOT_TRACE);
            return TraceData.builder().sample(false).build();
        } else {
            final String parentSpanId = request.getAttachment(RpcAttachment.ParentSpanId.getName());
            final String traceId = request.getAttachment(RpcAttachment.TraceId.getName());
            final String spanId = request.getAttachment(RpcAttachment.SpanId.getName());

            if (traceId != null && spanId != null) {
                reportTraceIdIfSampled(reporter, new CertainTraceId(traceId));
                SpanId span = getSpanId(traceId, spanId, parentSpanId);
                return TraceData.builder().sample(true).spanId(span).build();
            }
        }
    }
    reportTraceIdIfSampled(reporter, TraceId.NOT_TRACE);
    return TraceData.builder().build();
}

开发者ID:YanXs，项目名称:nighthawk，代码行数:23，代码来源:BraveDubboServerRequestAdapter.java

示例2: beginTrace

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
protected void beginTrace(Beginning beginning) {
    ClientTracer clientTracer = getClientTracer();
    if (clientTracer != null) {
        try {
            SpanId spanId = clientTracer.startNewSpan(beginning.spanName);
            if (spanId != null) {
                joinTracingLoop();
                submitBinaryAnnotation(clientTracer, beginning.annotations);
                setClientSent(clientTracer, beginning.address, beginning.port, beginning.spanName);
            }
        } catch (Exception e) {
            if (inTracingLoop()) {
                clientTracer.setClientSent();
            }
        }
    }
}

开发者ID:YanXs，项目名称:nighthawk，代码行数:18，代码来源:ClientTracerSupport.java

示例3: getTraceData

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
@Override
public TraceData getTraceData() {
    String sampled = tracingHeader.getSampled();
    if (sampled == null || sampled.equals("0")) {
        return TraceData.builder().sample(false).build();
    } else {
        final String parentSpanId = tracingHeader.getParentSpanId();
        final String traceId = tracingHeader.getTraceId();
        final String spanId = tracingHeader.getSpanId();

        if (traceId != null && spanId != null) {
            SpanId span = getSpanId(traceId, spanId, parentSpanId);
            return TraceData.builder().sample(true).spanId(span).build();
        }
    }
    return TraceData.builder().build();
}

开发者ID:YanXs，项目名称:nighthawk，代码行数:18，代码来源:KafkaServerRequestAdapter.java

示例4: getTraceData

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
@Override
public TraceData getTraceData() {
    final String sampled = rpcContext.getAttachment(BraveHttpHeaders.Sampled.getName());
    if (sampled != null) {
        if (sampled.equals("0") || sampled.toLowerCase().equals("false")) {
            return TraceData.builder().sample(false).build();
        } else {
            // final String parentSpanId = rpcContext.getAttachment(BraveHttpHeaders.ParentSpanId.getName());
            final String traceId = rpcContext.getAttachment(BraveHttpHeaders.TraceId.getName());
            final String spanId = rpcContext.getAttachment(BraveHttpHeaders.SpanId.getName());

            if (traceId != null && spanId != null) {

                SpanId span = getSpanId(traceId, IdConversion.convertToString(IdConversion.convertToLong(spanId) + 1L), spanId);
                return TraceData.builder().sample(true).spanId(span).build();
            }
        }
    }
    return TraceData.builder().build();
}

开发者ID:xiaomin0322，项目名称:dubbo_plus，代码行数:21，代码来源:DubboProviderRequestAdapter.java

示例5: addSpanIdToRequest

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
@Override
public void addSpanIdToRequest(SpanId spanId) {
    if (spanId == null) {
        rpcContext.setAttachment(BraveHttpHeaders.Sampled.getName(), "0");
    } else {
        rpcContext.setAttachment(BraveHttpHeaders.Sampled.getName(), "1");

        rpcContext.setAttachment(BraveHttpHeaders.TraceId.getName(), IdConversion.convertToString(spanId.getTraceId()));

        rpcContext.setAttachment(BraveHttpHeaders.SpanId.getName(), IdConversion.convertToString(spanId.getSpanId()));

        // if (spanId.getParentSpanId() != null) {
        // rpcContext.setAttachment(BraveHttpHeaders.ParentSpanId.getName(), IdConversion.convertToString(spanId.getParentSpanId()));
        // } else {
        // rpcContext.setAttachment(BraveHttpHeaders.ParentSpanId.getName(), IdConversion.convertToString(0L));
        // }
    }
}

开发者ID:xiaomin0322，项目名称:dubbo_plus，代码行数:19，代码来源:DubboConsumerRequestAdapter.java

示例6: onCalled

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
private void onCalled(final DeliveryContext context, final Message msg) {
  final String action = msg.headers().get(Headers.Action.getName());
  final SpanId span = localTracer.startNewSpan(msg.address(), msg.address());

  LoggingDC.put(span);

  if (logger.isDebugEnabled()) {
    logger.debug("Publish.Receive ({}): address={}, reply={}, headers={}", action, msg.address(), msg.replyAddress(), msg.headers());
  }

  try {
    context.next();
  } finally {
    localTracer.finishSpan();

    LoggingDC.removeAll();
  }
}

开发者ID:emmanuelidi，项目名称:vertx-zipkin，代码行数:19，代码来源:ZipkinEventBusServerInterceptor.java

示例7: getTraceData

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
@Override
public TraceData getTraceData() {
  final String sampled = msg.headers().get(BraveHttpHeaders.Sampled.getName());
  if (sampled != null) {
    if ("0".equals(sampled) || "false".equals(sampled.toLowerCase())) {
      return TraceData.builder().sample(false).build();
    } else {
      final String parentSpanId = msg.headers().get(BraveHttpHeaders.ParentSpanId.getName());
      final String traceId = msg.headers().get(BraveHttpHeaders.TraceId.getName());
      final String spanId = msg.headers().get(BraveHttpHeaders.SpanId.getName());
      if (traceId != null && spanId != null) {
        final SpanId span = SpanId.builder()
            .traceId(IdConversion.convertToLong(traceId))
            .spanId(IdConversion.convertToLong(spanId))
            .parentId(parentSpanId == null ? null : IdConversion.convertToLong(parentSpanId))
            .build();
        return TraceData.builder().sample(true).spanId(span).build();
      }
    }
  }
  return TraceData.builder().build();
}

开发者ID:emmanuelidi，项目名称:vertx-zipkin，代码行数:23，代码来源:ZipkinEventBusServerRequestAdapter.java

示例8: getTraceData

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
@Override
public TraceData getTraceData() {
    String sampled = exchange.getIn().getHeader(ZipkinConstants.SAMPLED, "0", String.class);
    if (sampled.equals("0") || sampled.toLowerCase().equals("false")) {
        return TraceData.builder().sample(false).build();
    } else {
        String traceId = exchange.getIn().getHeader(ZipkinConstants.TRACE_ID, String.class);
        String spanId = exchange.getIn().getHeader(ZipkinConstants.SPAN_ID, String.class);
        String parentSpanId = exchange.getIn().getHeader(ZipkinConstants.PARENT_SPAN_ID, String.class);
        if (traceId != null && spanId != null) {
            SpanId span = createSpanId(traceId, spanId, parentSpanId);
            return TraceData.builder().sample(true).spanId(span).build();
        }
    }
    return TraceData.builder().build();
}

开发者ID:HydAu，项目名称:Camel，代码行数:17，代码来源:ZipkinServerRequestAdapter.java

示例9: addSpanIdToRequest

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
@Override
public void addSpanIdToRequest(SpanId spanId) {
    if (spanId == null) {
        request.addAttachment(RpcAttachment.Sampled.getName(), "0");
    } else {
        request.addAttachment(RpcAttachment.Sampled.getName(), "1");
        request.addAttachment(RpcAttachment.TraceId.getName(), IdConversion.convertToString(spanId.traceId));
        request.addAttachment(RpcAttachment.SpanId.getName(), IdConversion.convertToString(spanId.spanId));
        if (spanId.nullableParentId() != null) {
            request.addAttachment(RpcAttachment.ParentSpanId.getName(), IdConversion.convertToString(spanId.parentId));
        }
        request.addAttachment(RpcAttachment.SpanName.getName(), getSpanName());
    }
}

开发者ID:YanXs，项目名称:nighthawk，代码行数:15，代码来源:BraveDubboClientRequestAdapter.java

示例10: startTracing

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
protected TracingHeader startTracing(String topic) {
    SpanId spanId = brave.clientTracer().startNewSpan("kafka - " + topic);
    TracingHeader tp = null;
    if (spanId != null) {
        tp = new TracingHeader();
        tp.setTraceId(IdConversion.convertToString(spanId.traceId));
        tp.setSpanId(IdConversion.convertToString(spanId.spanId));
        tp.setParentSpanId(IdConversion.convertToString(spanId.parentId));
        tp.setSampled("1");
    }
    return tp;
}

开发者ID:YanXs，项目名称:nighthawk，代码行数:13，代码来源:AbstractTracingSerializer.java

示例11: handleInvocation

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
@Override protected Object handleInvocation(Object proxy, Method method, Object[] args)
    throws Throwable {
  // Only join traces, don't start them. This prevents LocalCollector's thread from amplifying.
  if (brave.serverSpanThreadBinder().getCurrentServerSpan() != null &&
      brave.serverSpanThreadBinder().getCurrentServerSpan().getSpan() != null
      // Only trace named statements for now, since that's what we use
      && method.getName().equals("executeAsync") && args[0] instanceof NamedBoundStatement) {
    NamedBoundStatement statement = (NamedBoundStatement) args[0];

    SpanId spanId = brave.clientTracer().startNewSpan(statement.name);

    // o.a.c.tracing.Tracing.newSession must use the same format for the key zipkin
    if (version.compareTo(ProtocolVersion.V4) >= 0) {
      statement.enableTracing();
      statement.setOutgoingPayload(singletonMap("zipkin", ByteBuffer.wrap(spanId.bytes())));
    }

    brave.clientTracer().setClientSent(); // start the span and store it
    brave.clientTracer()
        .submitBinaryAnnotation("cql.query", statement.preparedStatement().getQueryString());
    cache.put(statement, brave.clientSpanThreadBinder().getCurrentClientSpan());
    // let go of the client span as it is only used for the RPC (will have no local children)
    brave.clientSpanThreadBinder().setCurrentSpan(null);
    return new BraveResultSetFuture(target.executeAsync(statement), brave);
  }
  try {
    return method.invoke(target, args);
  } catch (InvocationTargetException e) {
    if (e.getCause() instanceof RuntimeException) throw e.getCause();
    throw e;
  }
}

开发者ID:liaominghua，项目名称:zipkin，代码行数:33，代码来源:TracedSession.java

示例12: handleInvocation

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
@Override protected Object handleInvocation(Object proxy, Method method, Object[] args)
    throws Throwable {
  // Only join traces, don't start them. This prevents LocalCollector's thread from amplifying.
  if (brave.serverSpanThreadBinder().getCurrentServerSpan() != null &&
      brave.serverSpanThreadBinder().getCurrentServerSpan().getSpan() != null
      && method.getName().equals("executeAsync") && args[0] instanceof BoundStatement) {
    BoundStatement statement = (BoundStatement) args[0];

    // via an internal class z.s.cassandra3.NamedBoundStatement, toString() is a nice name
    SpanId spanId = brave.clientTracer().startNewSpan(statement.toString());

    // o.a.c.tracing.Tracing.newSession must use the same format for the key zipkin
    if (version.compareTo(ProtocolVersion.V4) >= 0) {
      statement.enableTracing();
      statement.setOutgoingPayload(singletonMap("zipkin", ByteBuffer.wrap(spanId.bytes())));
    }

    brave.clientTracer().setClientSent(); // start the span and store it
    brave.clientTracer()
        .submitBinaryAnnotation("cql.query", statement.preparedStatement().getQueryString());
    cache.put(statement, brave.clientSpanThreadBinder().getCurrentClientSpan());
    // let go of the client span as it is only used for the RPC (will have no local children)
    brave.clientSpanThreadBinder().setCurrentSpan(null);
    return new BraveResultSetFuture(target.executeAsync(statement), brave);
  }
  try {
    return method.invoke(target, args);
  } catch (InvocationTargetException e) {
    if (e.getCause() instanceof RuntimeException) throw e.getCause();
    throw e;
  }
}

开发者ID:liaominghua，项目名称:zipkin，代码行数:33，代码来源:TracedSession.java

示例13: put

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
public static void put(final SpanId id) {
  if (id != null) {
    put(TRACE_ID, toHexString(id.traceId));
  } else {
    removeAll();
  }
}

开发者ID:emmanuelidi，项目名称:vertx-zipkin，代码行数:8，代码来源:LoggingDC.java

示例14: addSpanIdToRequest

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
@Override
public void addSpanIdToRequest(@Nullable SpanId spanId) {
  if (spanId == null) {
    msg.headers().add(BraveHttpHeaders.Sampled.getName(), "0");
  } else {
    msg.headers().add(BraveHttpHeaders.Sampled.getName(), "1");
    msg.headers().add(BraveHttpHeaders.TraceId.getName(), IdConversion.convertToString(spanId.traceId));
    msg.headers().add(BraveHttpHeaders.SpanId.getName(), IdConversion.convertToString(spanId.spanId));
    if (spanId.nullableParentId() != null) {
      msg.headers().add(BraveHttpHeaders.ParentSpanId.getName(), IdConversion.convertToString(spanId.parentId));
    }
  }
}

开发者ID:emmanuelidi，项目名称:vertx-zipkin，代码行数:14，代码来源:ZipkinEventBusClientRequestAdapter.java

示例15: addSpanIdToRequest

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
@Override
public void addSpanIdToRequest(@Nullable SpanId spanId) {
    if (spanId == null) {
        exchange.getIn().setHeader(ZipkinConstants.SAMPLED, "0");
    } else {
        exchange.getIn().setHeader(ZipkinConstants.SAMPLED, "1");
        exchange.getIn().setHeader(ZipkinConstants.TRACE_ID, IdConversion.convertToString(spanId.getTraceId()));
        exchange.getIn().setHeader(ZipkinConstants.SPAN_ID, IdConversion.convertToString(spanId.getSpanId()));
        if (spanId.getParentSpanId() != null) {
            exchange.getIn().setHeader(ZipkinConstants.PARENT_SPAN_ID, IdConversion.convertToString(spanId.getParentSpanId()));
        }
    }
}

开发者ID:HydAu，项目名称:Camel，代码行数:14，代码来源:ZipkinClientRequestAdapter.java

示例16: getSpanId

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
private SpanId getSpanId(String traceId, String spanId, String parentSpanId) {
    return SpanId.builder()
            .traceId(convertToLong(traceId))
            .spanId(convertToLong(spanId))
            .parentId(parentSpanId == null ? null : convertToLong(parentSpanId)).build();
}

开发者ID:YanXs，项目名称:nighthawk，代码行数:7，代码来源:BraveDubboServerRequestAdapter.java

示例17: getSpanId

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
private SpanId getSpanId(String traceId, String spanId, String parentSpanId) {
    if (parentSpanId != null) {
        return SpanId.create(IdConversion.convertToLong(traceId), IdConversion.convertToLong(spanId), IdConversion.convertToLong(parentSpanId));
    }
    return SpanId.create(IdConversion.convertToLong(traceId), IdConversion.convertToLong(spanId), null);
}

开发者ID:xiaomin0322，项目名称:dubbo_plus，代码行数:7，代码来源:DubboProviderRequestAdapter.java

示例18: createSpanId

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
public static SpanId createSpanId(String traceId, String spanId, String parentSpanId) {
    if (parentSpanId != null) {
        return SpanId.create(IdConversion.convertToLong(traceId), IdConversion.convertToLong(spanId), IdConversion.convertToLong(parentSpanId));
    }
    return SpanId.create(IdConversion.convertToLong(traceId), IdConversion.convertToLong(spanId), null);
}

开发者ID:HydAu，项目名称:Camel，代码行数:7，代码来源:ZipkinHelper.java

示例19: executeWithClientSpan

import com.github.kristofa.brave.SpanId; //导入依赖的package包/类
private ResultSet executeWithClientSpan(BoundStatement boundStatement) {

        ClientTracer clientTracer = brave.clientTracer();

        SpanId spanId = clientTracer.startNewSpan("query");
        clientTracer.submitBinaryAnnotation("sql.query", boundStatement.preparedStatement().getQueryString());

        ByteBuffer traceHeaders = ByteBuffer.wrap(spanId.bytes());
        boundStatement.setOutgoingPayload(Collections.singletonMap("zipkin", traceHeaders));

        clientTracer.setClientSent();
        ResultSet resultSet = session.execute(boundStatement.enableTracing());
        clientTracer.setClientReceived();

        return resultSet;
    }

开发者ID:hawkular，项目名称:hawkular-apm，代码行数:17，代码来源:UserDAO.java

注：本文中的com.github.kristofa.brave.SpanId类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java JacksonJodaDateFormat类代码示例发布时间：2022-05-22

Java VcsConfiguration类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19168|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9982|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8322|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8691|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8635|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9651|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8618|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7995|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8649|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7532|2022-11-06

客服电话

电子邮件

Java SpanId类代码示例

示例1: getTraceData

示例2: beginTrace

示例3: getTraceData

示例4: getTraceData

示例5: addSpanIdToRequest

示例6: onCalled

示例7: getTraceData

示例8: getTraceData

示例9: addSpanIdToRequest

示例10: startTracing

示例11: handleInvocation

示例12: handleInvocation

示例13: put

示例14: addSpanIdToRequest

示例15: addSpanIdToRequest

示例16: getSpanId

示例17: getSpanId

示例18: createSpanId

示例19: executeWithClientSpan

请发表评论

全部评论

上一篇：

下一篇：

CVE-2022-33173

bradtraversy/iweather: Ionic 3 mobile we

Ramotion/android-ui-animation-components

一个小时快速搭建微信小程序教程

joaomh/curso-de-matlab

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053