源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：io.lettuce.core.ScoredValue

示例1
@Override
@Deprecated
public List<ScoredValue<V>> zrangebyscoreWithScores(K key,
    String min, String max) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("min", min);
  span.setTag("max", max);
  try {
    return commands.zrangebyscoreWithScores(key, min, max);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例2
@Override
@Deprecated
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key,
    String max, String min, long offset,
    long count) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  span.setTag("offset", offset);
  span.setTag("count", count);
  try {
    return commands.zrevrangebyscoreWithScores(key, max, min, offset, count);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例3
@Override
@Deprecated
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key,
    String max, String min) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  try {
    return commands.zrevrangebyscoreWithScores(key, max, min);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例4
@Override
@Deprecated
public List<ScoredValue<V>> zrangebyscoreWithScores(K key,
    String min, String max, long offset, long
    count) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("min", min);
  span.setTag("max", max);
  span.setTag("offset", offset);
  span.setTag("count", count);
  try {
    return commands.zrangebyscoreWithScores(key, min, max, offset, count);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例5
@Override
@Deprecated
public List<ScoredValue<V>> zrangebyscoreWithScores(K key, double min,
    double max) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("min", min);
  span.setTag("max", max);
  try {
    return commands.zrangebyscoreWithScores(key, min, max);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例6
@Override
@Deprecated
public List<ScoredValue<V>> zrangebyscoreWithScores(K key, double min,
    double max) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("min", min);
  span.setTag("max", max);
  try {
    return commands.zrangebyscoreWithScores(key, min, max);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例7
@Override
@Deprecated
public List<ScoredValue<V>> zrangebyscoreWithScores(K key,
    String min, String max) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("min", min);
  span.setTag("max", max);
  try {
    return commands.zrangebyscoreWithScores(key, min, max);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例8
@Override
@Deprecated
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key,
    String max, String min, long offset,
    long count) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  span.setTag("offset", offset);
  span.setTag("count", count);
  try {
    return commands.zrevrangebyscoreWithScores(key, max, min, offset, count);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例9
@Override
@Deprecated
public List<ScoredValue<V>> zrangebyscoreWithScores(K key,
    String min, String max, long offset, long
    count) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("min", min);
  span.setTag("max", max);
  span.setTag("offset", offset);
  span.setTag("count", count);
  try {
    return commands.zrangebyscoreWithScores(key, min, max, offset, count);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例10
@Override
@Deprecated
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key,
    String max, String min) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  try {
    return commands.zrevrangebyscoreWithScores(key, max, min);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例11
@Override
@Deprecated
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key, double max,
    double min, long offset, long count) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  span.setTag("offset", offset);
  span.setTag("count", count);
  try {
    return commands.zrevrangebyscoreWithScores(key, max, min, offset, count);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例12
@Override
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key,
    Range<? extends Number> range, Limit
    limit) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("range", nullable(range));
  span.setTag("limit", nullable(limit));
  try {
    return commands.zrevrangebyscoreWithScores(key, range, limit);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例13
@Override
@Deprecated
public List<ScoredValue<V>> zrangebyscoreWithScores(K key, double min,
    double max, long offset, long count) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("min", min);
  span.setTag("max", max);
  span.setTag("offset", offset);
  span.setTag("count", count);
  try {
    return commands.zrangebyscoreWithScores(key, min, max, offset, count);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例14
@Override
@Deprecated
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key, double max,
    double min, long offset, long count) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  span.setTag("offset", offset);
  span.setTag("count", count);
  try {
    return commands.zrevrangebyscoreWithScores(key, max, min, offset, count);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例15
@Override
@Deprecated
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key, double max,
    double min) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  try {
    return commands.zrevrangebyscoreWithScores(key, max, min);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例16
@Override
@Deprecated
public List<ScoredValue<V>> zrangebyscoreWithScores(K key,
    String min, String max) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("min", min);
  span.setTag("max", max);
  try {
    return commands.zrangebyscoreWithScores(key, min, max);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例17
@Override
@Deprecated
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key, double max,
    double min, long offset, long count) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  span.setTag("offset", offset);
  span.setTag("count", count);
  try {
    return commands.zrevrangebyscoreWithScores(key, max, min, offset, count);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例18
@Override
@Deprecated
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key,
    String max, String min, long offset,
    long count) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  span.setTag("offset", offset);
  span.setTag("count", count);
  try {
    return commands.zrevrangebyscoreWithScores(key, max, min, offset, count);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例19
@Override
public List<ScoredValue<V>> zrevrangeWithScores(K key, long start,
    long stop) {
  Span span = helper.buildSpan("zrevrangeWithScores", key);
  span.setTag("start", start);
  span.setTag("stop", stop);
  try {
    return commands.zrevrangeWithScores(key, start, stop);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例20
@Override
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key,
    Range<? extends Number> range) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("range", nullable(range));
  try {
    return commands.zrevrangebyscoreWithScores(key, range);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例21
/**
 * Method to write anomaly timestamps from ({@link com.yahoo.sherlock.model.AnomalyReport}) to redis.
 * @param anomalyTimestamps map : key - redis key, value - list of timestamps as {@link io.lettuce.core.ScoredValue}
 */
public void writeAnomalyTimestampsToRedis(Map<String, List<ScoredValue<byte[]>>> anomalyTimestamps) {
    RedisConnection<byte[]> conn = binary();
    List<RedisFuture> futures = new LinkedList<>();
    AsyncCommands<byte[]> cmd = conn.async();
    cmd.setAutoFlushCommands(false);
    log.info("Adding {} anomaly timestamps to redis", anomalyTimestamps.size());
    for (Map.Entry<String, List<ScoredValue<byte[]>>> anomalyTimestamp : anomalyTimestamps.entrySet()) {
        futures.add(cmd.zadd(encode(anomalyTimestamp.getKey()), anomalyTimestamp.getValue().toArray(new ScoredValue[anomalyTimestamp.getValue().size()])));
        futures.add(cmd.expire(encode(anomalyTimestamp.getKey()), expirationTime));
    }
    cmd.flushCommands();
    awaitRaw(futures);
    log.info("Added all anomaly timestamps to redis");
}
示例22
@Override
public RedisFuture<List<ScoredValue<V>>> zrangeWithScores(
    K key, long start, long stop) {
  Span span = helper.buildSpan("zrangeWithScores", key);
  span.setTag("start", start);
  span.setTag("stop", stop);
  return prepareRedisFuture(commands.zrangeWithScores(key, start, stop), span);
}
示例23
@Override
public List<ScoredValue<V>> zrevrangebyscoreWithScores(K key,
    Range<? extends Number> range) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("range", nullable(range));
  try {
    return commands.zrevrangebyscoreWithScores(key, range);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}
示例24
@Override
@Deprecated
public RedisFuture<List<ScoredValue<V>>> zrangebyscoreWithScores(
    K key, double min, double max) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("min", min);
  span.setTag("max", max);
  return prepareRedisFuture(commands.zrangebyscoreWithScores(key, min, max), span);
}
示例25
@Override
@Deprecated
public RedisFuture<List<ScoredValue<V>>> zrevrangebyscoreWithScores(
    K key, double max, double min) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  return prepareRedisFuture(commands.zrevrangebyscoreWithScores(key, max, min), span);
}
示例26
@Override
@Deprecated
public RedisFuture<List<ScoredValue<V>>> zrevrangebyscoreWithScores(
    K key, String max, String min) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  return prepareRedisFuture(commands.zrevrangebyscoreWithScores(key, max, min), span);
}
示例27
@Override
public RedisFuture<List<ScoredValue<V>>> zrevrangebyscoreWithScores(
    K key, Range<? extends Number> range, Limit limit) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("range", nullable(range));
  span.setTag("limit", nullable(limit));
  return prepareRedisFuture(commands.zrevrangebyscoreWithScores(key, range, limit), span);
}
示例28
@Override
@Deprecated
public RedisFuture<List<ScoredValue<V>>> zrangebyscoreWithScores(
    K key, double min, double max) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("min", min);
  span.setTag("max", max);
  return prepareRedisFuture(commands.zrangebyscoreWithScores(key, min, max), span);
}
示例29
@Override
@Deprecated
public RedisFuture<List<ScoredValue<V>>> zrangebyscoreWithScores(
    K key, String min, String max) {
  Span span = helper.buildSpan("zrangebyscoreWithScores", key);
  span.setTag("min", min);
  span.setTag("max", max);
  return prepareRedisFuture(commands.zrangebyscoreWithScores(key, min, max), span);
}
示例30
@Override
@Deprecated
public RedisFuture<List<ScoredValue<V>>> zrevrangebyscoreWithScores(
    K key, String max, String min) {
  Span span = helper.buildSpan("zrevrangebyscoreWithScores", key);
  span.setTag("max", max);
  span.setTag("min", min);
  return prepareRedisFuture(commands.zrevrangebyscoreWithScores(key, max, min), span);
}