[Infra UI] Add AWS metrics to node detail page (#42153) (#43181)

* Add cloudId to metrics graphql query. * Add server-side TSVB model for aws cpu utilization * Use cloud id for cloud metrics * Add AWS layout to host page * Add cloudId to useMetadata * Refactor: move aws modules into separate directory * Add AWS network chart to node details * Add AWS Overview to node details * Add aws network packets chart to node details * Add TODO reference to aws network bytes model * Add AWS diskio ops to node details * Add AWS diskio bytes to node details * Check that cloudId is given when needed * Use network packets on node details AWS overview * Remove requires on layout level. * Fix layout creator type signature. * Add gaugeMax to layout types
elastic · Aug 13, 2019 · 7021666 · 7021666
1 parent 8b10071
commit 7021666
Show file tree

Hide file tree

Showing 23 changed files with 778 additions and 16 deletions.
diff --git a/x-pack/legacy/plugins/infra/common/graphql/types.ts b/x-pack/legacy/plugins/infra/common/graphql/types.ts
@@ -374,6 +374,12 @@ export interface InfraSnapshotMetricInput {
   /** The type of metric */
   type: InfraSnapshotMetricType;
 }
+
+export interface InfraNodeIdsInput {
+  nodeId: string;
+
+  cloudId?: string | null;
+}
 /** The properties to update the source with */
 export interface UpdateSourceInput {
   /** The name of the data source */
@@ -493,7 +499,7 @@ export interface SnapshotInfraSourceArgs {
   filterQuery?: string | null;
 }
 export interface MetricsInfraSourceArgs {
-  nodeId: string;
+  nodeIds: InfraNodeIdsInput;
 
   nodeType: InfraNodeType;
 
@@ -582,6 +588,12 @@ export enum InfraMetric {
   nginxRequestRate = 'nginxRequestRate',
   nginxActiveConnections = 'nginxActiveConnections',
   nginxRequestsPerConnection = 'nginxRequestsPerConnection',
+  awsOverview = 'awsOverview',
+  awsCpuUtilization = 'awsCpuUtilization',
+  awsNetworkBytes = 'awsNetworkBytes',
+  awsNetworkPackets = 'awsNetworkPackets',
+  awsDiskioBytes = 'awsDiskioBytes',
+  awsDiskioOps = 'awsDiskioOps',
   custom = 'custom',
 }
 
@@ -794,6 +806,7 @@ export namespace MetricsQuery {
     timerange: InfraTimerangeInput;
     metrics: InfraMetric[];
     nodeId: string;
+    cloudId?: string | null;
     nodeType: InfraNodeType;
   };
 

diff --git a/x-pack/legacy/plugins/infra/public/containers/metadata/use_metadata.ts b/x-pack/legacy/plugins/infra/public/containers/metadata/use_metadata.ts
@@ -44,5 +44,12 @@ export function useMetadata(
     filteredLayouts: (response && getFilteredLayouts(layouts, response.features)) || [],
     error: (error && error.message) || null,
     loading,
+    cloudId:
+      (response &&
+        response.info &&
+        response.info.cloud &&
+        response.info.cloud.instance &&
+        response.info.cloud.instance.id) ||
+      '',
   };
 }
diff --git a/x-pack/legacy/plugins/infra/public/containers/metrics/metrics.gql_query.ts b/x-pack/legacy/plugins/infra/public/containers/metrics/metrics.gql_query.ts
@@ -12,11 +12,17 @@ export const metricsQuery = gql`
     $timerange: InfraTimerangeInput!
     $metrics: [InfraMetric!]!
     $nodeId: ID!
+    $cloudId: ID
     $nodeType: InfraNodeType!
   ) {
     source(id: $sourceId) {
       id
-      metrics(nodeId: $nodeId, timerange: $timerange, metrics: $metrics, nodeType: $nodeType) {
+      metrics(
+        nodeIds: { nodeId: $nodeId, cloudId: $cloudId }
+        timerange: $timerange
+        metrics: $metrics
+        nodeType: $nodeType
+      ) {
         id
         series {
           id

diff --git a/x-pack/legacy/plugins/infra/public/containers/metrics/with_metrics.tsx b/x-pack/legacy/plugins/infra/public/containers/metrics/with_metrics.tsx
@@ -28,6 +28,7 @@ interface WithMetricsProps {
   layouts: InfraMetricLayout[];
   nodeType: InfraNodeType;
   nodeId: string;
+  cloudId: string;
   sourceId: string;
   timerange: InfraTimerangeInput;
 }
@@ -39,6 +40,7 @@ export const WithMetrics = ({
   timerange,
   nodeType,
   nodeId,
+  cloudId,
 }: WithMetricsProps) => {
   const metrics = layouts.reduce(
     (acc, item) => {
@@ -57,6 +59,7 @@ export const WithMetrics = ({
         metrics,
         nodeType,
         nodeId,
+        cloudId,
         timerange,
       }}
     >

diff --git a/x-pack/legacy/plugins/infra/public/graphql/introspection.json b/x-pack/legacy/plugins/infra/public/graphql/introspection.json
@@ -471,12 +471,12 @@
             "description": "",
             "args": [
               {
-                "name": "nodeId",
+                "name": "nodeIds",
                 "description": "",
                 "type": {
                   "kind": "NON_NULL",
                   "name": null,
-                  "ofType": { "kind": "SCALAR", "name": "ID", "ofType": null }
+                  "ofType": { "kind": "INPUT_OBJECT", "name": "InfraNodeIdsInput", "ofType": null }
                 },
                 "defaultValue": null
               },
@@ -2316,6 +2316,33 @@
         "enumValues": null,
         "possibleTypes": null
       },
+      {
+        "kind": "INPUT_OBJECT",
+        "name": "InfraNodeIdsInput",
+        "description": "",
+        "fields": null,
+        "inputFields": [
+          {
+            "name": "nodeId",
+            "description": "",
+            "type": {
+              "kind": "NON_NULL",
+              "name": null,
+              "ofType": { "kind": "SCALAR", "name": "ID", "ofType": null }
+            },
+            "defaultValue": null
+          },
+          {
+            "name": "cloudId",
+            "description": "",
+            "type": { "kind": "SCALAR", "name": "ID", "ofType": null },
+            "defaultValue": null
+          }
+        ],
+        "interfaces": null,
+        "enumValues": null,
+        "possibleTypes": null
+      },
       {
         "kind": "ENUM",
         "name": "InfraMetric",
@@ -2486,6 +2513,42 @@
             "isDeprecated": false,
             "deprecationReason": null
           },
+          {
+            "name": "awsOverview",
+            "description": "",
+            "isDeprecated": false,
+            "deprecationReason": null
+          },
+          {
+            "name": "awsCpuUtilization",
+            "description": "",
+            "isDeprecated": false,
+            "deprecationReason": null
+          },
+          {
+            "name": "awsNetworkBytes",
+            "description": "",
+            "isDeprecated": false,
+            "deprecationReason": null
+          },
+          {
+            "name": "awsNetworkPackets",
+            "description": "",
+            "isDeprecated": false,
+            "deprecationReason": null
+          },
+          {
+            "name": "awsDiskioBytes",
+            "description": "",
+            "isDeprecated": false,
+            "deprecationReason": null
+          },
+          {
+            "name": "awsDiskioOps",
+            "description": "",
+            "isDeprecated": false,
+            "deprecationReason": null
+          },
           { "name": "custom", "description": "", "isDeprecated": false, "deprecationReason": null }
         ],
         "possibleTypes": null

diff --git a/x-pack/legacy/plugins/infra/public/graphql/types.ts b/x-pack/legacy/plugins/infra/public/graphql/types.ts
@@ -374,6 +374,12 @@ export interface InfraSnapshotMetricInput {
   /** The type of metric */
   type: InfraSnapshotMetricType;
 }
+
+export interface InfraNodeIdsInput {
+  nodeId: string;
+
+  cloudId?: string | null;
+}
 /** The properties to update the source with */
 export interface UpdateSourceInput {
   /** The name of the data source */
@@ -493,7 +499,7 @@ export interface SnapshotInfraSourceArgs {
   filterQuery?: string | null;
 }
 export interface MetricsInfraSourceArgs {
-  nodeId: string;
+  nodeIds: InfraNodeIdsInput;
 
   nodeType: InfraNodeType;
 
@@ -582,6 +588,12 @@ export enum InfraMetric {
   nginxRequestRate = 'nginxRequestRate',
   nginxActiveConnections = 'nginxActiveConnections',
   nginxRequestsPerConnection = 'nginxRequestsPerConnection',
+  awsOverview = 'awsOverview',
+  awsCpuUtilization = 'awsCpuUtilization',
+  awsNetworkBytes = 'awsNetworkBytes',
+  awsNetworkPackets = 'awsNetworkPackets',
+  awsDiskioBytes = 'awsDiskioBytes',
+  awsDiskioOps = 'awsDiskioOps',
   custom = 'custom',
 }
 
@@ -794,6 +806,7 @@ export namespace MetricsQuery {
     timerange: InfraTimerangeInput;
     metrics: InfraMetric[];
     nodeId: string;
+    cloudId?: string | null;
     nodeType: InfraNodeType;
   };
 

diff --git a/x-pack/legacy/plugins/infra/public/pages/metrics/index.tsx b/x-pack/legacy/plugins/infra/public/pages/metrics/index.tsx
@@ -86,7 +86,7 @@ export const MetricDetail = withMetricPageProviders(
         }
         const { sourceId } = useContext(Source.Context);
         const layouts = layoutCreator(theme);
-        const { name, filteredLayouts, loading: metadataLoading } = useMetadata(
+        const { name, filteredLayouts, loading: metadataLoading, cloudId } = useMetadata(
           nodeId,
           nodeType,
           layouts,
@@ -148,6 +148,7 @@ export const MetricDetail = withMetricPageProviders(
                     timerange={timeRange as InfraTimerangeInput}
                     nodeType={nodeType}
                     nodeId={nodeId}
+                    cloudId={cloudId}
                   >
                     {({ metrics, error, loading, refetch }) => {
                       if (error) {