scouter.lang.pack.XLogPack类的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(6.0k)|赞(0)|评价(0)|浏览(126)

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

XLogPack介绍

[英]Object that contains one transaction information
[中]对象,该对象包含一个事务信息

代码示例

代码示例来源:origin: scouter-project/scouter

public static XLogPack txperf(long endtime, long txid, int service_hash, String serviceName, int elapsed, int cpu,
               int sqlCount, int sqlTime, String remoteAddr, String error, long visitor) {
  XLogPack pack = new XLogPack();
  pack.cpu = cpu;
  pack.endTime = endtime;
  pack.elapsed = elapsed;
  DataProxy.sendServiceName(service_hash, serviceName);
  pack.service = service_hash;
  pack.kbytes = 0;
  pack.status = 0;
  pack.sqlCount = sqlCount;
  pack.sqlTime = sqlTime;
  pack.txid = txid;
  pack.ipaddr = IPUtil.toBytes(remoteAddr);
  pack.userid = visitor;
  if (error != null) {
    pack.error = DataProxy.sendError(error);
  }
  MeterService.getInstance().add(pack.elapsed, pack.sqlTime, pack.apicallTime, pack.queuingTime, error != null);
  DataProxy.sendXLog(pack);
  MeterUsers.add(pack.userid);
  return pack;
}

代码示例来源:origin: scouter-project/scouter

public static void sendXLog(XLogPack p) {
  p.objHash = conf.getObjHash();
  sendDirect(p);
  if (conf._log_udp_xlog_enabled) {
    Logger.println(p.toString());
  }
}
public static void send(SummaryPack p) {

代码示例来源:origin: scouter-project/scouter

public static XLogPack txperf(long endtime, long txid, int service_hash, String serviceName, int elapsed, int cpu,
               int sqlCount, int sqlTime, String remoteAddr, String error, long visitor) {
  XLogPack pack = new XLogPack();
  pack.cpu = cpu;
  pack.endTime = endtime;
  pack.elapsed = elapsed;
  DataProxy.sendServiceName(service_hash, serviceName);
  pack.service = service_hash;
  pack.kbytes = 0;
  pack.status = 0;
  pack.sqlCount = sqlCount;
  pack.sqlTime = sqlTime;
  pack.txid = txid;
  pack.ipaddr = IPUtil.toBytes(remoteAddr);
  pack.userid = visitor;
  if (error != null) {
    pack.error = DataProxy.sendError(error);
  }
  MeterService.getInstance().add(pack.elapsed, pack.sqlTime, pack.apicallTime, pack.queuingTime, error != null);
  DataProxy.sendXLog(pack);
  MeterUsers.add(pack.userid);
  return pack;
}

代码示例来源:origin: scouter-project/scouter

public static void sendXLog(XLogPack p) {
  p.objHash = conf.getObjHash();
  sendDirect(p);
  if (conf._log_udp_xlog_enabled) {
    Logger.println(p.toString());
  }
}
public static void send(SummaryPack p) {

代码示例来源:origin: scouter-project/scouter

public static Pack createNonExt(byte packType) {
  switch (packType) {
    case MAP:
      return new MapPack();
    case PERF_COUNTER:
      return new PerfCounterPack();
    case PERF_STATUS:
      return new StatusPack();
    case XLOG_PROFILE:
      return new XLogProfilePack();
    case XLOG:
      return new XLogPack();
    case TEXT:
      return new TextPack();
    case ALERT:
      return new AlertPack();
    case OBJECT:
      return new ObjectPack();
    case STACK:
      return new StackPack();
    case SUMMARY:
      return new SummaryPack();
    case BATCH:
      return new BatchPack();
    case PERF_INTERACTION_COUNTER:
      return new InteractionPerfCounterPack();
    default:
      return null;
  }
}

代码示例来源:origin: io.github.scouter-project/scouter-agent-java

public static void sendXLog(XLogPack p) {
  p.objHash = conf.getObjHash();
  sendDirect(p);
  if (conf._log_udp_xlog_enabled) {
    Logger.println(p.toString());
  }
}
public static void send(SummaryPack p) {

代码示例来源:origin: scouter-project/scouter

return new XLogProfilePack();
case XLOG:
  return new XLogPack();
case TEXT:
  return new TextPack();

代码示例来源:origin: scouter-project/scouter

return new XLogProfilePack();
case XLOG:
  return new XLogPack();
case TEXT:
  return new TextPack();

代码示例来源:origin: scouter-project/scouter

return new XLogProfilePack();
case XLOG:
  return new XLogPack();
case TEXT:
  return new TextPack();

代码示例来源:origin: scouter-project/scouter

return new XLogProfilePack();
case XLOG:
  return new XLogPack();
case TEXT:
  return new TextPack();

代码示例来源:origin: scouter-project/scouter

XLogPack pack = new XLogPack();

代码示例来源:origin: scouter-project/scouter

XLogPack pack = new XLogPack();

代码示例来源:origin: scouter-project/scouter

XLogPack pack = new XLogPack();
pack.cpu = (int) (SysJMX.getCurrentThreadCPU() - ctx.startCpu);

代码示例来源:origin: scouter-project/scouter

XLogPack pack = new XLogPack();
pack.cpu = (int) (SysJMX.getCurrentThreadCPU() - ctx.startCpu);

代码示例来源:origin: io.github.scouter-project/scouter-agent-java

public static XLogPack txperf(long endtime, long txid, int service_hash, String serviceName, int elapsed, int cpu,
               int sqlCount, int sqlTime, String remoteAddr, String error, long visitor) {
  XLogPack pack = new XLogPack();
  pack.cpu = cpu;
  pack.endTime = endtime;
  pack.elapsed = elapsed;
  DataProxy.sendServiceName(service_hash, serviceName);
  pack.service = service_hash;
  pack.kbytes = 0;
  pack.status = 0;
  pack.sqlCount = sqlCount;
  pack.sqlTime = sqlTime;
  pack.txid = txid;
  pack.ipaddr = IPUtil.toBytes(remoteAddr);
  pack.userid = visitor;
  if (error != null) {
    pack.error = DataProxy.sendError(error);
  }
  MeterService.getInstance().add(pack.elapsed, pack.sqlTime, pack.apicallTime, pack.queuingTime, error != null);
  DataProxy.sendXLog(pack);
  MeterUsers.add(pack.userid);
  return pack;
}

代码示例来源:origin: io.github.scouter-project/scouter-agent-java

return new XLogProfilePack();
case XLOG:
  return new XLogPack();
case TEXT:
  return new TextPack();

代码示例来源:origin: io.github.scouter-project/scouter-common

return new XLogProfilePack();
case XLOG:
  return new XLogPack();
case TEXT:
  return new TextPack();

代码示例来源:origin: io.github.scouter-project/scouter-server

return new XLogProfilePack();
case XLOG:
  return new XLogPack();
case TEXT:
  return new TextPack();

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

public static XLogPack makeXLogPack(SpanPack pack, ScouterConfig conf) {
  XLogPack xlog = new XLogPack();
  xlog.endTime = pack.timestamp + pack.elapsed;
  xlog.objHash = pack.objHash;
  xlog.service = pack.name;
  xlog.txid = pack.txid;
  xlog.gxid = pack.gxid;
  xlog.caller = pack.caller;
  xlog.elapsed = pack.elapsed;
  xlog.error = pack.error;
  xlog.xType = XLogTypes.ZIPKIN_SPAN;
  String loginColumnString = map1stMatchingTagNames(pack, conf.getLoginTag());
  if (StringUtil.isNotEmpty(loginColumnString)) {
    xlog.login = sendLogin(loginColumnString);
  }
  String descColumnString = map1stMatchingTagNames(pack, conf.getDescTag());
  if (StringUtil.isNotEmpty(descColumnString)) {
    xlog.desc = sendLogin(descColumnString);
  }
  xlog.text1 = mapTagNames(pack, conf.getText1Tag());
  xlog.text2 = mapTagNames(pack, conf.getText2Tag());
  xlog.text3 = mapTagNames(pack, conf.getText3Tag());
  xlog.text4 = mapTagNames(pack, conf.getText4Tag());
  xlog.text5 = mapTagNames(pack, conf.getText5Tag());
  return xlog;
}

代码示例来源:origin: io.github.scouter-project/scouter-agent-java

XLogPack pack = new XLogPack();

相关文章