Class HistogramDataPointRpc

src/tsd/HistogramDataPointRpc.java:43–248

The class responsible for writing histograms from Telnet calls or HTTP requests. @since 2.4

 * @since 2.4
 */
public class HistogramDataPointRpc extends PutDataPointRpc 
  implements TelnetRpc, HttpRpc {
  
  /** Type ref for the histo pojo. */
  private static final TypeReference<ArrayList<HistogramPojo>> TYPE_REF =
      new TypeReference<ArrayList<HistogramPojo>>() {};
      
  /** Whether or not histograms are enabled. */
  private final boolean enabled;

  /**
   * Default ctor. Checks the "tsd.core.histograms.config" value to see if 
   * histograms are enabled. If they are not, then exceptions are returned. 
   * @param config A non-null config to pull data from.
   */
  public HistogramDataPointRpc(final Config config) {
    super(config);
    // drats, since we can't look at the manager we'll look at the settings.
    final String histo_config = config.getString("tsd.core.histograms.config");
    if (Strings.isNullOrEmpty(histo_config)) {
      enabled = false;
    } else {
      enabled = true;
    }
  }

  @Override
  public void execute(final TSDB tsdb, final HttpQuery query) throws IOException {
    http_requests.incrementAndGet();
    
    if (!enabled) {
      throw new BadRequestException(HttpResponseStatus.SERVICE_UNAVAILABLE,
          "Histogram storage has not been enabled. Check the "
          + "'tsd.core.histograms.config' configuration.");
    }
    
    // only accept POST
    if (query.method() != HttpMethod.POST) {
      throw new BadRequestException(HttpResponseStatus.METHOD_NOT_ALLOWED,
          "Method not allowed", "The HTTP method [" + query.method().getName() +
          "] is not permitted for this endpoint");
    }
    
    final List<HistogramPojo> dps = query.serializer()
        .parsePutV1(HistogramPojo.class, TYPE_REF);
    processDataPoint(tsdb, query, dps);
  }
  
  @Override
  protected Deferred<Object> importDataPoint(final TSDB tsdb, 
                                             final String[] words) {
    if (!enabled) {
      throw new IllegalArgumentException(
          "Histogram storage has not been enabled. Check the "
          + "'tsd.core.histograms.config' configuration.");
    }
    
    words[0] = null; // Ditch the "histogram".