Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[HHQ-3216] Split out metric data APIs into MetricDataApi.
- Loading branch information
Ryan Morgan
committed
Jul 21, 2009
1 parent
c957a74
commit fca49cd
Showing
17 changed files
with
1,106 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,222 @@ | ||
| import org.hyperic.hq.hqapi1.ErrorCode; | ||
|
|
||
| class MetricdataController extends ApiController { | ||
|
|
||
| private Closure getMetricDataXML(r) { | ||
| { doc -> | ||
| MetricData(resourceId: r.resource.id, | ||
| resourceName: r.resource.name, | ||
| metricId: r.metric.id, | ||
| metricName: r.metric.template.name) { | ||
| // TODO: Backend does not always return data in asending order | ||
| for (dp in r.data.sort {a, b -> a.timestamp <=> b.timestamp}) { | ||
| DataPoint(timestamp : dp.timestamp, | ||
| value : dp.value) | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private Closure getLastMetricDataXML(r) { | ||
| { doc -> | ||
| LastMetricData(resourceId: r.resource.id, | ||
| resourceName: r.resource.name, | ||
| metricId: r.metric.id, | ||
| metricName: r.metric.template.name) { | ||
| if (!r.data) { | ||
| log.warn("No data found for metric id=" + r.metric.id) | ||
| } else { | ||
| DataPoint(timestamp : r.data.timestamp, | ||
| value : r.data.value) | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Validate metric parameters, returning a Closure representing the error | ||
| * or null if the parameters are valid | ||
| */ | ||
| private Closure validateParameters(metricIds, start, end) { | ||
|
|
||
| if (!start) { | ||
| return getFailureXML(ErrorCode.INVALID_PARAMETERS, | ||
| "Start time not given") | ||
| } | ||
| if (!end) { | ||
| return getFailureXML(ErrorCode.INVALID_PARAMETERS, | ||
| "End time not given") | ||
| } | ||
| if (end < start) { | ||
| return getFailureXML(ErrorCode.INVALID_PARAMETERS, | ||
| "End time cannot be < start time") | ||
| } | ||
| return validateParameters(metricIds) | ||
| } | ||
|
|
||
| /** | ||
| * Validate metric parameters, returning a Closure representing the error | ||
| * or null if the parameters are valid | ||
| */ | ||
| private Closure validateParameters(metricIds) { | ||
| if (metricIds == null || metricIds.size() == 0) { | ||
| return getFailureXML(ErrorCode.INVALID_PARAMETERS, | ||
| "Metric id not given") | ||
| } | ||
|
|
||
| for (mid in metricIds) { | ||
| if (!mid) { | ||
| return getFailureXML(ErrorCode.INVALID_PARAMETERS, | ||
| "Metric id not given") | ||
| } | ||
| def metric = metricHelper.findMeasurementById(mid) | ||
| if (!metric) { | ||
| return getFailureXML(ErrorCode.OBJECT_NOT_FOUND, | ||
| "Metric id " + mid + " not found") | ||
| } | ||
| } | ||
| return null | ||
| } | ||
|
|
||
| def get(params) { | ||
| def metricId = params.getOne("id")?.toInteger() | ||
| def start = params.getOne("start")?.toLong() | ||
| def end = params.getOne("end")?.toLong() | ||
|
|
||
| def failureXml = validateParameters([metricId], start, end) | ||
| def metric = metricHelper.findMeasurementById(metricId) | ||
| def data | ||
| if (!failureXml) { | ||
| try { | ||
| data = metric.getData(start, end) | ||
| } catch (Exception e) { | ||
| log.error("UnexpectedError: " + e.getMessage(), e); | ||
| failureXml = getFailureXML(ErrorCode.UNEXPECTED_ERROR) | ||
| } | ||
| } | ||
|
|
||
| renderXml() { | ||
| MetricDataResponse() { | ||
| if (failureXml) { | ||
| out << failureXml | ||
| } else { | ||
| def result = [resource: metric.resource, metric: metric, | ||
| data: data] | ||
| out << getSuccessXML() | ||
| out << getMetricDataXML(result) | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| def getLast(params) { | ||
| def metricId = params.getOne("id")?.toInteger() | ||
|
|
||
| def failureXml = validateParameters([metricId]) | ||
| def metric = metricHelper.findMeasurementById(metricId) | ||
| def data | ||
| if (!failureXml) { | ||
| try { | ||
| data = metric.getLastDataPoint() | ||
| } catch (Exception e) { | ||
| log.error("UnexpectedError: " + e.getMessage(), e); | ||
| failureXml = getFailureXML(ErrorCode.UNEXPECTED_ERROR) | ||
| } | ||
| } | ||
|
|
||
| renderXml() { | ||
| LastMetricDataResponse() { | ||
| if (failureXml) { | ||
| out << failureXml | ||
| } else { | ||
| def result = [resource: metric.resource, metric: metric, | ||
| data: data] | ||
| out << getSuccessXML() | ||
| out << getLastMetricDataXML(result) | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| def getMulti(params) { | ||
| def metricIds = params.get("id")*.toInteger() | ||
| def start = params.getOne("start")?.toLong() | ||
| def end = params.getOne("end")?.toLong() | ||
|
|
||
| def failureXml = validateParameters(metricIds, start, end) | ||
|
|
||
| def results = [] | ||
|
|
||
| if (!failureXml) { | ||
| for (m in metricIds) { | ||
| try { | ||
| // TODO: Switch to collections based API | ||
| def metric = metricHelper.findMeasurementById(m) | ||
| def data = metric.getData(start, end) | ||
| results << [resource: metric.resource, | ||
| metric: metric, data: data] | ||
| } catch (Exception e) { | ||
| log.error("UnexpectedError: " + e.getMessage(), e); | ||
| failureXml = getFailureXML(ErrorCode.UNEXPECTED_ERROR) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| renderXml() { | ||
| MetricsDataResponse() { | ||
| if (failureXml) { | ||
| out << failureXml | ||
| } else { | ||
| out << getSuccessXML() | ||
| for (result in results) { | ||
| out << getMetricDataXML(result) | ||
| } | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| def getMultiLast(params) { | ||
| def metricIds = params.get("id")*.toInteger() | ||
|
|
||
| def failureXml = validateParameters(metricIds) | ||
|
|
||
| def results = [] | ||
|
|
||
| if (!failureXml) { | ||
| for (m in metricIds) { | ||
| try { | ||
| def metric = metricHelper.findMeasurementById(m) | ||
| def data = metric.getLastDataPoint() | ||
| results << [resource: metric.resource, | ||
| metric: metric, data: data] | ||
| } catch (Exception e) { | ||
| log.error("UnexpectedError: " + e.getMessage(), e); | ||
| failureXml = getFailureXML(ErrorCode.UNEXPECTED_ERROR) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| renderXml() { | ||
| LastMetricsDataResponse() { | ||
| if (failureXml) { | ||
| out << failureXml | ||
| } else { | ||
| out << getSuccessXML() | ||
| for (result in results) { | ||
| out << getLastMetricDataXML(result) | ||
| } | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| def put(params) { | ||
|
|
||
| renderXml() { | ||
| StatusResponse() { | ||
| out << getFailureXML(ErrorCode.NOT_IMPLEMENTED); | ||
| } | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.