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

QueryRequest.endTs介绍

[英]Only return traces where all Span#timestamp() are at or before this time in epoch milliseconds. Defaults to current time.
[中]仅返回所有Span#timestamp（）在该时间或之前的记录道（以历元毫秒为单位）。默认为当前时间。

代码示例

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

TimestampRange timestampRange(QueryRequest request) {
 long oldestData = Math.max(System.currentTimeMillis() - indexTtl * 1000, 0); // >= 1970
 TimestampRange result = new TimestampRange();
 result.startMillis = Math.max((request.endTs() - request.lookback()), oldestData);
 result.startUUID = UUIDs.startOf(result.startMillis);
 result.endMillis = Math.max(request.endTs(), oldestData);
 result.endUUID = UUIDs.endOf(result.endMillis);
 return result;
}

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

Set<String> traceIdsDescendingByTimestamp(QueryRequest request) {
 if (!searchEnabled) return Collections.emptySet();
 Collection<TraceIdTimestamp> traceIdTimestamps =
  request.serviceName() != null
   ? traceIdTimestampsByServiceName(request.serviceName())
   : spansByTraceIdTimeStamp.keySet();
 long endTs = request.endTs() * 1000;
 long startTs = endTs - request.lookback() * 1000;
 if (traceIdTimestamps == null || traceIdTimestamps.isEmpty()) return Collections.emptySet();
 Set<String> result = new LinkedHashSet<>();
 for (TraceIdTimestamp traceIdTimestamp : traceIdTimestamps) {
  if (traceIdTimestamp.timestamp >= startTs || traceIdTimestamp.timestamp <= endTs) {
   result.add(traceIdTimestamp.lowTraceId);
  }
 }
 return result;
}

代码示例来源：origin: io.github.jeqo.zipkin/zipkin-storage-kafka

long start = queryRequest.endTs() - queryRequest.lookback();
long end = queryRequest.endTs();

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

request.serviceName(),
     request.spanName(),
     request.endTs() * 1000,
     request.lookback() * 1000,
     traceIndexFetchSize));
   selectTraceIdsByServiceName.newCall(
     request.serviceName(),
     request.endTs() * 1000,
     request.lookback() * 1000,
     traceIndexFetchSize));
   selectTraceIdsByAnnotation.newCall(
     annotationKey,
     request.endTs() * 1000,
     request.lookback() * 1000,
     traceIndexFetchSize));
FlatMapper<List<String>, Set<Pair>> flatMapper =
  selectTraceIdsByServiceNames.newFlatMapper(
    request.endTs() * 1000, request.lookback() * 1000, traceIndexFetchSize);
callsToIntersect.add(getServiceNames().flatMap(flatMapper));

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

timestamp < (endTs() - lookback()) * 1000 ||
timestamp > endTs() * 1000) {
return false;