Class LoadMetricsServer


public class LoadMetricsServer extends HttpForwardingMetricsServer
A metrics server that records and reports metrics for a set of running topologies.
  • Field Details

    • DEFAULT_REPORT_INTERVAL

      public static final long DEFAULT_REPORT_INTERVAL
      See Also:
    • DEFAULT_WINDOW_INTERVAL

      public static final long DEFAULT_WINDOW_INTERVAL
      See Also:
  • Method Details

    • addCommandLineOptions

      public static void addCommandLineOptions(org.apache.commons.cli.Options options)
      Add Command line options for configuring the output of this.
      Parameters:
      options - command line options to update
    • monitorFor

      public void monitorFor(double execTimeMins, Nimbus.Iface client, Collection<String> topoNames) throws Exception
      Monitor the list of topologies for the given time frame.
      Parameters:
      execTimeMins - how long to monitor for
      client - the client to use when monitoring
      topoNames - the names of the topologies to monitor
      Throws:
      Exception - on any error
    • handle

      public void handle(IMetricsConsumer.TaskInfo taskInfo, Collection<IMetricsConsumer.DataPoint> dataPoints, String topologyId)
      Specified by:
      handle in class HttpForwardingMetricsServer