Method processLookup

src/tsd/SearchRpc.java:174–297

Processes a lookup query against the tsdb-meta table, returning (and resolving) the TSUIDs of any series that matched the query. @param tsdb The TSDB to which we belong @param query The HTTP query to work with @param search_query A search query configured with at least a metric or a list of tag pair

(final TSDB tsdb, final HttpQuery query, 
      final SearchQuery search_query)

   * @since 2.1
   */
  private void processLookup(final TSDB tsdb, final HttpQuery query, 
      final SearchQuery search_query) {
    if (search_query.getMetric() == null && 
        (search_query.getTags() == null || search_query.getTags().size() < 1)) {
      throw new BadRequestException(
          "Missing metric and tags. Please supply at least one value.");
    }
    final long start = System.currentTimeMillis();
    
    class MetricCB implements Callback<Object, String> {
      final Map<String, Object> series;
      MetricCB(final Map<String, Object> series) {
        this.series = series;
      }
      
      @Override
      public Object call(final String name) throws Exception {
        series.put("metric", name);
        return null;
      }
    }
    
    class TagsCB implements Callback<Object, HashMap<String, String>> {
      final Map<String, Object> series;
      TagsCB(final Map<String, Object> series) {
        this.series = series;
      }
      
      @Override
      public Object call(final HashMap<String, String> names) throws Exception {
        series.put("tags", names);
        return null;
      }
    }
    
    class Serialize implements Callback<Object, ArrayList<Object>> {
      final List<Object> results;
      Serialize(final List<Object> results) {
        this.results = results;
      }
      
      @Override
      public Object call(final ArrayList<Object> ignored) throws Exception {
        search_query.setResults(results);
        search_query.setTime(System.currentTimeMillis() - start);
        query.sendReply(query.serializer().formatSearchResultsV1(search_query));
        return null;
      }
    }
    
    class LookupCB implements Callback<Deferred<Object>, List<byte[]>> {
      @Override
      public Deferred<Object> call(final List<byte[]> tsuids) throws Exception {
        final List<Object> results = new ArrayList<Object>(tsuids.size());
        search_query.setTotalResults(tsuids.size());
        
        final ArrayList<Deferred<Object>> deferreds = 
            new ArrayList<Deferred<Object>>(tsuids.size());