public class MetricsServer extends Object
Constructor and Description |
---|
MetricsServer() |
Modifier and Type | Method and Description |
---|---|
void |
addNumericData(Set<org.rhq.core.domain.measurement.MeasurementDataNumeric> dataSet,
RawDataInsertedCallback callback) |
Iterable<AggregateNumericMetric> |
calculateAggregates()
Computes and stores aggregates for all buckets that are ready to be aggregated.
|
protected org.joda.time.DateTime |
currentHour() |
List<org.rhq.core.domain.measurement.composite.MeasurementDataNumericHighLowComposite> |
findDataForGroup(List<Integer> scheduleIds,
long beginTime,
long endTime,
int numberOfBuckets) |
Iterable<org.rhq.core.domain.measurement.composite.MeasurementDataNumericHighLowComposite> |
findDataForResource(int scheduleId,
long beginTime,
long endTime,
int numberOfBuckets) |
RawNumericMetric |
findLatestValueForResource(int scheduleId) |
AggregateNumericMetric |
getSummaryAggregate(int scheduleId,
long beginTime,
long endTime) |
AggregateNumericMetric |
getSummaryAggregate(List<Integer> scheduleIds,
long beginTime,
long endTime) |
void |
init(boolean isNewServerInstall,
long serverInstallTime) |
protected org.joda.time.DateTime |
roundDownToHour(long timestamp) |
void |
setConfiguration(MetricsConfiguration configuration) |
void |
setDAO(MetricsDAO dao) |
void |
setDateTimeService(DateTimeService dateTimeService) |
void |
shutdown() |
public void setDAO(MetricsDAO dao)
public void setConfiguration(MetricsConfiguration configuration)
public void setDateTimeService(DateTimeService dateTimeService)
public void init(boolean isNewServerInstall, long serverInstallTime)
protected org.joda.time.DateTime currentHour()
protected org.joda.time.DateTime roundDownToHour(long timestamp)
public void shutdown()
public RawNumericMetric findLatestValueForResource(int scheduleId)
public Iterable<org.rhq.core.domain.measurement.composite.MeasurementDataNumericHighLowComposite> findDataForResource(int scheduleId, long beginTime, long endTime, int numberOfBuckets)
public List<org.rhq.core.domain.measurement.composite.MeasurementDataNumericHighLowComposite> findDataForGroup(List<Integer> scheduleIds, long beginTime, long endTime, int numberOfBuckets)
public AggregateNumericMetric getSummaryAggregate(int scheduleId, long beginTime, long endTime)
public AggregateNumericMetric getSummaryAggregate(List<Integer> scheduleIds, long beginTime, long endTime)
public void addNumericData(Set<org.rhq.core.domain.measurement.MeasurementDataNumeric> dataSet, RawDataInsertedCallback callback)
public Iterable<AggregateNumericMetric> calculateAggregates()
Copyright © 2008-2013 Red Hat, Inc.. All Rights Reserved.