Class HttpQuery

src/tsd/HttpQuery.java:60–1007

Binds together an HTTP request and the channel on which it was received. It makes it easier to provide a few utility methods to respond to the requests.

 * requests.
 */
final class HttpQuery extends AbstractHttpQuery {

  private static final Logger LOG = LoggerFactory.getLogger(HttpQuery.class);

  private static final String HTML_CONTENT_TYPE = "text/html; charset=UTF-8";

  /** The maximum implemented API version, set when the user doesn't */
  private static final int MAX_API_VERSION = 1;

  /**
   * Keep track of the latency of HTTP requests.
   */
  private static final Histogram httplatency =
    new Histogram(16000, (short) 2, 100);

  /** Maps Content-Type to a serializer */
  private static HashMap<String, Constructor<? extends HttpSerializer>>
    serializer_map_content_type = null;

  /** Maps query string names to a serializer */
  private static HashMap<String, Constructor<? extends HttpSerializer>>
    serializer_map_query_string = null;

  /** Caches serializer implementation information for user access */
  private static ArrayList<HashMap<String, Object>> serializer_status = null;

  /** API version parsed from the incoming request */
  private int api_version = 0;

  /** The serializer to use for parsing input and responding */
  private HttpSerializer serializer = null;

  /** Whether or not to show stack traces in the output */
  private final boolean show_stack_trace;

  /**
   * Constructor.
   * @param request The request in this HTTP query.
   * @param chan The channel on which the request was received.
   */
  public HttpQuery(final TSDB tsdb, final HttpRequest request, final Channel chan) {
    super(tsdb, request, chan);
    this.show_stack_trace =
      tsdb.getConfig().getBoolean("tsd.http.show_stack_trace");
    this.serializer = new HttpJsonSerializer(this);
  }

  /**
   * Collects the stats and metrics tracked by this instance.
   * @param collector The collector to use.
   */
  public static void collectStats(final StatsCollector collector) {
    collector.record("http.latency", httplatency, "type=all");
  }

  /**
   * Returns the version for an API request. If the request was for a deprecated
   * API call (such as /q, /suggest, /logs) this value will be 0. If the request