zipkin.internal.Util类的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(181)

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

Util介绍

暂无

代码示例

代码示例来源：origin: io.zipkin.java/zipkin-transport-scribe

  1. /**
  2.  * {@link CollectorSampler#isSampled(Span) samples spans} to reduce load on the storage system.
  3.  * Defaults to always sample.
  4.  */
  5. public Builder sampler(CollectorSampler sampler) {
  6.  this.sampler = checkNotNull(sampler, "sampler");
  7.  return this;
  8. }

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

  1. @Override public String toString() {
  2.  return "(" + table + "," + partitionKey + "," + Util.toLowerHex(traceId) + ")";
  3. }

代码示例来源：origin: io.zipkin.java/zipkin-storage-mysql

  1. if (equal(saService, caService)) caService = null;
  2.  .traceId(toLowerHex(traceIdHi != null ? traceIdHi : 0L, traceIdLo))
  3.  .parentId(parentId != null ? toLowerHex(parentId) : null)
  4.  .id(toLowerHex(spanId));

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

  1. static List<String> annotationKeys(QueryRequest request) {
  2.  if (request.annotations.isEmpty() && request.binaryAnnotations.isEmpty()) {
  3.   return Collections.emptyList();
  4.  }
  5.  checkArgument(request.serviceName != null, "serviceName needed with annotation query");
  6.  Set<String> annotationKeys = new LinkedHashSet<>();
  7.  for (String a : request.annotations) { // doesn't include CORE_ANNOTATIONS
  8.   annotationKeys.add(request.serviceName + ":" + a);
  9.  }
  10.  for (Map.Entry<String, String> b : request.binaryAnnotations.entrySet()) {
  11.   annotationKeys.add(request.serviceName + ":" + b.getKey() + ":" + b.getValue());
  12.  }
  13.  return sortedList(annotationKeys);
  14. }

代码示例来源：origin: io.zipkin.java/zipkin-storage-elasticsearch

  1. static GregorianCalendar midnightUTC(long epochMillis) {
  2.  GregorianCalendar result = new GregorianCalendar(UTC);
  3.  result.setTimeInMillis(Util.midnightUTC(epochMillis));
  4.  return result;
  5. }

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

  1. @Override public ListenableFuture<List<DependencyLink>> getDependencies(long endTs,
  2.   @Nullable Long lookback) {
  3.  List<Date> days = getDays(endTs, lookback);
  4.  try {
  5.   BoundStatement bound = CassandraUtil.bindWithName(selectDependencies, "select-dependencies")
  6.     .setList("days", days);
  7.   return transform(session.executeAsync(bound), ConvertDependenciesResponse.INSTANCE);
  8.  } catch (RuntimeException ex) {
  9.   return immediateFailedFuture(ex);
  10.  }
  11. }

代码示例来源：origin: io.zipkin.java/zipkin-storage-elasticsearch-http

  1. /** Note: this runs on the {@link okhttp3.OkHttpClient#dispatcher() dispatcher} thread! */
  2.  @Override public void onResponse(okhttp3.Call call, Response response) {
  3.   try {
  4.    delegate.onSuccess(parseResponse(response, bodyConverter));
  5.   } catch (Throwable e) {
  6.    propagateIfFatal(e);
  7.    delegate.onError(e);
  8.   }
  9.  }
  10. }

代码示例来源：origin: io.zipkin.java/zipkin-storage-elasticsearch

  1. @Override public List<String> apply(SearchResponse input) {
  2.  Iterator<Aggregation> aggregations = input.getAggregations() != null
  3.    ? input.getAggregations().iterator()
  4.    : null;
  5.  if (aggregations == null) {
  6.   return ImmutableList.of();
  7.  }
  8.  ImmutableSet.Builder<String> result = ImmutableSet.builder();
  9.  while (aggregations.hasNext()) {
  10.   addBucketKeys(aggregations.next(), result);
  11.  }
  12.  return Util.sortedList(result.build());
  13. }

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

  1. @VisibleForTesting void write(List<DependencyLink> links, long timestampMillis) {
  2.  long midnight = Util.midnightUTC(timestampMillis);
  3.  Dependencies deps = Dependencies.create(midnight, midnight /* ignored */, links);
  4.  ByteBuffer thrift = deps.toThrift();
  5.  Futures.getUnchecked(storeDependencies(midnight, thrift));
  6. }

代码示例来源：origin: io.zipkin.java/zipkin-storage-mysql

  1. @Override
  2. public List<DependencyLink> getDependencies(long endTs, @Nullable Long lookback) {
  3.  try (Connection conn = datasource.getConnection()) {
  4.   if (schema.hasPreAggregatedDependencies) {
  5.    List<Date> days = getDays(endTs, lookback);
  6.    List<DependencyLink> unmerged = context.get(conn)
  7.      .select(schema.dependencyLinkFields)
  8.      .from(ZIPKIN_DEPENDENCIES)
  9.      .where(ZIPKIN_DEPENDENCIES.DAY.in(days))
  10.      .fetch((Record l) -> DependencyLink.builder()
  11.        .parent(l.get(ZIPKIN_DEPENDENCIES.PARENT))
  12.        .child(l.get(ZIPKIN_DEPENDENCIES.CHILD))
  13.        .callCount(l.get(ZIPKIN_DEPENDENCIES.CALL_COUNT))
  14.        .errorCount(maybeGet(l, ZIPKIN_DEPENDENCIES.ERROR_COUNT, 0L))
  15.        .build()
  16.      );
  17.    return DependencyLinker.merge(unmerged);
  18.   } else {
  19.    return aggregateDependencies(endTs, lookback, conn);
  20.   }
  21.  } catch (SQLException e) {
  22.   throw new RuntimeException("Error querying dependencies for endTs "
  23.     + endTs + " and lookback " + lookback + ": " + e.getMessage());
  24.  }
  25. }

代码示例来源：origin: io.zipkin.java/zipkin-storage-elasticsearch

  1. @Override public void accept(List<Span> spans, Callback<Void> callback) {
  2.  if (spans.isEmpty()) {
  3.   callback.onSuccess(null);
  4.   return;
  5.  }
  6.  try {
  7.   indexSpans(client.bulkSpanIndexer(), spans).execute(callback);
  8.  } catch (Throwable t) {
  9.   propagateIfFatal(t);
  10.   callback.onError(t);
  11.  }
  12. }

代码示例来源：origin: io.zipkin.java/transport-kafka

  1. /** The zookeeper connect string, ex. 127.0.0.1:2181. No default */
  2. public Builder zookeeper(String zookeeper) {
  3.  this.zookeeper = checkNotNull(zookeeper, "zookeeper");
  4.  return this;
  5. }

代码示例来源：origin: io.zipkin.java/zipkin-storage-elasticsearch

  1. @Override public ListenableFuture<List<Span>> getRawTrace(long traceIdHigh, long traceIdLow) {
  2.  String traceIdHex = Util.toLowerHex(strictTraceId ? traceIdHigh : 0L, traceIdLow);
  3.  return client.findSpans(catchAll, termQuery("traceId", traceIdHex));
  4. }

代码示例来源：origin: io.zipkin.java/zipkin-storage-elasticsearch

  1. /**
  2.  * The index prefix to use when generating daily index names. Defaults to zipkin.
  3.  */
  4. public Builder index(String index) {
  5.  this.index = checkNotNull(index, "index");
  6.  return this;
  7. }

代码示例来源：origin: io.zipkin.java/zipkin-storage-elasticsearch-http

  1. @Override
  2. public void getRawTrace(long traceIdHigh, long traceIdLow, Callback<List<Span>> callback) {
  3.  String traceIdHex = Util.toLowerHex(strictTraceId ? traceIdHigh : 0L, traceIdLow);
  4.  SearchRequest request = SearchRequest.create(asList(allIndices), SPAN)
  5.   .term("traceId", traceIdHex);
  6.  submit(search.newCall(request, NULLABLE_SPANS), callback);
  7. }

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

  1. /** Keyspace to store span and index data. Defaults to "zipkin" */
  2. public Builder keyspace(String keyspace) {
  3.  this.keyspace = checkNotNull(keyspace, "keyspace");
  4.  return this;
  5. }

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

  1. static void streamSpansToStorage(
  2.   JavaDStream<byte[]> stream,
  3.   ReadSpans readSpans,
  4.   AdjustAndConsumeSpansSharingTraceId adjustAndConsumeSpansSharingTraceId
  5. ) {
  6.  JavaDStream<Span> spans = stream.flatMap(readSpans);
  7.  // TODO: plug in some filter to drop spans regardless of trace ID
  8.  // spans = spans.filter(spanFilter);
  9.  JavaPairDStream<String, Iterable<Span>> tracesById = spans
  10.    .mapToPair(s -> new Tuple2<>(Util.toLowerHex(s.traceIdHigh, s.traceId), s))
  11.    .groupByKey();
  12.  tracesById.foreachRDD(rdd -> {
  13.   rdd.values().foreachPartition(adjustAndConsumeSpansSharingTraceId);
  14.  });
  15. }

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

  1. /** Comma separated list of host addresses part of Cassandra cluster. You can also specify a custom port with 'host:port'. Defaults to localhost on port 9042 **/
  2. public Builder contactPoints(String contactPoints) {
  3.  this.contactPoints = checkNotNull(contactPoints, "contactPoints");
  4.  return this;
  5. }

代码示例来源：origin: io.zipkin.java/zipkin-transport-scribe

  1. /** Category zipkin spans will be consumed from. Defaults to "zipkin" */
  2. public Builder category(String category) {
  3.  this.category = checkNotNull(category, "category");
  4.  return this;
  5. }

代码示例来源：origin: io.zipkin.java/zipkin-transport-kafka

  1. /**
  2.  * {@link CollectorSampler#isSampled(Span) samples spans} to reduce load on the storage system.
  3.  * Defaults to always sample.
  4.  */
  5. public Builder sampler(CollectorSampler sampler) {
  6.  this.sampler = checkNotNull(sampler, "sampler");
  7.  return this;
  8. }

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

Util

相关文章

    查看更多

    热门标签

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

    最新文章

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