Merge pull request #65 from oslabs-beta/ms/settingsSidebar_cardsDisplay

Ms/settings sidebar cards display

Author: ggbong734

ksqLight/package-lock.json

@@ -19,11 +19,12 @@
     "concurrently": "^7.2.2",
     "cors": "^2.8.5",
     "cross-env": "^7.0.3",
-    "electron": "^19.0.6",
+    "electron": "^19.0.9",
     "express": "^4.18.1",
     "express-graphql": "^0.12.0",
     "graphql": "^15.8.0",
     "ksqldb-js": "^1.1.0",
+    "livereload": "^0.9.3",
     "react": "^18.2.0",
     "react-dom": "^18.2.0",
     "react-router-dom": "^6.3.0",

ksqLight/package.json

@@ -10,6 +10,7 @@ const {
     GraphQLList,
     GraphQLInt,
     GraphQLNonNull,
+    GraphQLBoolean,
 } = require('graphql');
 
 //---------------Internal Module Imports----------------
@@ -48,14 +49,82 @@ const RootQueryType = new GraphQLObjectType({
                 metric: { type: GraphQLNonNull(GraphQLString)},
                 start: { type: GraphQLNonNull(GraphQLInt)},
                 end: { type: GraphQLNonNull(GraphQLInt)},
-                resolution: { type: GraphQLNonNull(GraphQLInt)}
+                resolution: { type: GraphQLNonNull(GraphQLInt)},
+                prometheusURL: { type: GraphQLNonNull(GraphQLString)}
             },
-            resolve: (parent, {start, end, resolution, metric}) => {
-                return axios.get(`http://localhost:9090/api/v1/query_range?step=${resolution}s&end=${end}&start=${start}&query=${queryTypes[metric]}`)
-                .then(res => res.data.data.result[0].values)
+            resolve: (parent, {start, end, resolution, metric, prometheusURL}) => {
+                if (prometheusURL[prometheusURL.length] === '/') prometheusURL = prometheusURL.slice(0, prometheusURL.length);
+
+                return axios.get(`${prometheusURL}/api/v1/query_range?step=${resolution}s&end=${end}&start=${start}&query=${queryTypes[metric]}`)
+                .then(res => {
+                    return res.data.data.result[0].values})
                 .catch(error => error);
             }
-        }
+        },
+        livenessIndicator: {
+            type: GraphQLBoolean,
+            description: 'Boolean value representing whether the ksqlDB server up and emitting metrics.',
+            args: {
+                prometheusURL: { type: GraphQLNonNull(GraphQLString)}
+            },
+            resolve: async (parent, { prometheusURL }) => {
+                try {
+                    return await axios.get(`${prometheusURL}/api/v1/query?query=ksql_ksql_engine_query_stats_liveness_indicator`)
+                    .then(res => res.data.data.result[0].value[1] === "1")
+                    .catch(error => {throw error});
+                } catch (error) {
+                    return error;
+                }
+            }
+        },
+        errorRate: {
+            type: GraphQLInt,
+            description: 'The number of messages that were consumed but not processed.',
+            args: {
+                prometheusURL: { type: GraphQLNonNull(GraphQLString)}
+            },
+            resolve: async (parent, { prometheusURL }) => {
+                try {
+                    return await axios.get(`${prometheusURL}/api/v1/query?query=ksql_ksql_engine_query_stats_error_rate`)
+                    .then(res => Number(res.data.data.result[0].value[1]))
+                    .catch(error => {throw error});
+                } catch (error) {
+                    return error;
+                }
+            }
+        },
+        errorQueries: {
+            type: GraphQLInt,
+            description: 'The count of queries in ERROR state.',
+            args: {
+                prometheusURL: { type: GraphQLNonNull(GraphQLString)}
+            },
+            resolve: async (parent, { prometheusURL }) => {
+                try {
+                    return await axios.get(`${prometheusURL}/api/v1/query?query=ksql_ksql_engine_query_stats_error_queries`)
+                    .then(res => Number(res.data.data.result[0].value[1]))
+                    .catch(error => {throw error});
+                } catch (error) {
+                    return error;
+                }
+            }
+        },
+        bytesConsumed: {
+            type: GraphQLInt,
+            description: 'The total number of bytes consumed across all queries.',
+            args: {
+                prometheusURL: { type: GraphQLNonNull(GraphQLString)}
+            },
+            resolve: async (parent, { prometheusURL }) => {
+                try {
+                    return await axios.get(`${prometheusURL}/api/v1/query?query=ksql_ksql_engine_query_stats_bytes_consumed_total`)
+                    .then(res => Number(res.data.data.result[0].value[1]))
+                    .catch(error => {throw error});
+                } catch (error) {
+                    return error;
+                }
+            }
+        },
     })
 });
 
@@ -68,4 +137,4 @@ app.use('/graphql', graphqlHTTP({
     graphiql: true
 }));
 
-app.listen(5000, () => console.log('Server Running...'));
+app.listen(5001, () => console.log('Server Running...'));