Altered server to have additional query types to feed each of the four card metrics at once. The metric card components were adjusted to make appropriate requests for and properly display data returned from the server

Author: MichaelCSnyder

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----------------
@@ -55,10 +56,75 @@ const RootQueryType = new GraphQLObjectType({
                 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 => res.data.data.result[0].values)
+                .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;
+                }
+            }
+        },
     })
 });
 
@@ -71,4 +137,4 @@ app.use('/graphql', graphqlHTTP({
     graphiql: true
 }));
 
-app.listen(5000, () => console.log('Server Running...'));
+app.listen(5001, () => console.log('Server Running...'));