rpc.js 2.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374
  1. /**
  2. * Licensed to the Apache Software Foundation (ASF) under one or more
  3. * contributor license agreements. See the NOTICE file distributed with this
  4. * work for additional information regarding copyright ownership. The ASF
  5. * licenses this file to you under the Apache License, Version 2.0 (the
  6. * "License"); you may not use this file except in compliance with the License.
  7. * You may obtain a copy of the License at
  8. *
  9. * http://www.apache.org/licenses/LICENSE-2.0
  10. *
  11. * Unless required by applicable law or agreed to in writing, software
  12. * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
  13. * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
  14. * License for the specific language governing permissions and limitations under
  15. * the License.
  16. */
  17. var App = require('app');
  18. /**
  19. * @class
  20. *
  21. * This is a view for showing cluster CPU metrics
  22. *
  23. * @extends App.ChartLinearTimeView
  24. * @extends Ember.Object
  25. * @extends Ember.View
  26. */
  27. App.ChartServiceMetricsHDFS_RPC = App.ChartLinearTimeView.extend({
  28. id: "service-metrics-hdfs-rpc",
  29. title: "RPC",
  30. yAxisFormatter: App.ChartLinearTimeView.TimeElapsedFormatter,
  31. url: function () {
  32. return App.formatUrl("/api/clusters/{clusterName}/hosts/{hostName}/host_components/NAMENODE?fields=metrics/rpc/RpcQueueTime_avg_time[{fromSeconds},{toSeconds},{stepSeconds}]", {
  33. clusterName: App.router.get('mainController.cluster').get('clusterName')
  34. }, "/data/services/metrics/hdfs/rpc.json");
  35. }.property('App.router.mainController.cluster'),
  36. transformToSeries: function (jsonData) {
  37. var seriesArray = [];
  38. if (jsonData && jsonData.metrics && jsonData.metrics.rpc) {
  39. for ( var name in jsonData.metrics.rpc) {
  40. var displayName;
  41. var seriesData = jsonData.metrics.rpc[name];
  42. switch (name) {
  43. case "RpcQueueTime_avg_time":
  44. displayName = "Queue Average Wait Time";
  45. break;
  46. default:
  47. break;
  48. }
  49. if (seriesData) {
  50. // Is it a string?
  51. if ("string" == typeof seriesData) {
  52. seriesData = JSON.parse(seriesData);
  53. }
  54. // We have valid data
  55. var series = {};
  56. series.name = displayName;
  57. series.data = [];
  58. for ( var index = 0; index < seriesData.length; index++) {
  59. series.data.push({
  60. x: seriesData[index][1],
  61. y: seriesData[index][0]
  62. });
  63. }
  64. seriesArray.push(series);
  65. }
  66. }
  67. }
  68. return seriesArray;
  69. }
  70. });