Merge pull request #69 from Lemoncode/feature/monitoring

Feature/monitoring

Author: JaimeSalas

.gitignore

@@ -31,3 +31,6 @@ app/
 lab/
 private.readme.md
 04-cloud/00-aks/03-virtual-kubelet/auth.json
+
+# Vagrant 
+.vagrant

03-cd/exercises/README.md

@@ -4,7 +4,7 @@
 
 ### 1. CI/CD de una Java + Gradle
 
-En el directorio raíz de este [código fuente](./jenkins-resources/calcultor), crea un `Jenkinsfile` que contenga un pipeline declarativa con los siguientes stages:
+En el directorio raíz de este [código fuente](./jenkins-resources), crea un `Jenkinsfile` que contenga un pipeline declarativa con los siguientes stages:
 
 * **Checkout** descarga de código desde un repositorio remoto, preferentemente utiliza GitHub.
 * **Compile** compilar el código fuente, para ello utilizar `gradlew compileJava`

06-monitoring/00-prometheus/.demos/01-counters-gauges/.start/batch/.dockerignore

@@ -0,0 +1,3 @@
+node_modules
+*.md 
+Dockerfile

06-monitoring/00-prometheus/.demos/01-counters-gauges/.start/batch/Dockerfile

@@ -0,0 +1,9 @@
+FROM node:16-alpine 
+
+WORKDIR /opt/app
+
+COPY . .
+
+RUN npm ci 
+
+CMD ["npm", "start"]

06-monitoring/00-prometheus/.demos/01-counters-gauges/.start/batch/batch.js

@@ -0,0 +1,17 @@
+const getRandom = (start, end) => Math.floor((Math.random() * end) + start);
+
+const randomBatchProcess = () => {
+  const jobs = getRandom(50, 500);
+  const failed = getRandom(1, 50);
+  const processed = jobs - failed;
+  return { jobs, failed, processed };
+};
+
+module.exports.batch = () => {
+  const intervalId = setInterval(() => {
+    const { jobs, failed, processed } = randomBatchProcess();
+    console.log(jobs, failed, processed);
+  }, 5_000);
+
+  return intervalId;
+};

06-monitoring/00-prometheus/.demos/01-counters-gauges/.start/batch/config.js

@@ -0,0 +1,3 @@
+module.exports = ({
+  port: +process.env.PORT || 3000,
+});

06-monitoring/00-prometheus/.demos/01-counters-gauges/.start/batch/index.js

@@ -0,0 +1,23 @@
+const express = require('express');
+const { port } = require('./config');
+const { batch } = require('./batch');
+
+const intervalId = batch();
+const app = express();
+
+app.get('/metrics', async (_, res) => {
+  try {
+    res.send('Not implemented yet');
+  } catch (ex) {
+    res.status(500).end(ex);
+  }
+});
+
+app.post('/stop', (_, res) => {
+  clearInterval(intervalId);
+  res.send('batch process stopped');
+});
+
+app.listen(port, () => {
+  console.log(`Listening at ${port}`);
+});